Dublin version of documentationdublin

Change-Id: I226c363bd565e7aacab8b7d20c9bb4aaceeb036b Issue-ID: DCAEGEN2-1603 Signed-off-by: maximesson <maxime.bonneau@est.tech>
author: maximesson <maxime.bonneau@est.tech> 2019-06-20 10:42:48 +0200
committer: maximesson <maxime.bonneau@est.tech> 2019-06-20 10:43:01 +0200
commit: 7ee84355e06aaefbe4a91af24ee27ca4f36d2f9b (patch)
tree: b743e17e557ddbda29f309ef9db57f1487e2a211
parent: c9a8aa4dc4e7641a4e5ab0f2a81cd8d15de3b41a (diff)
7 files changed, 227 insertions, 192 deletions
diff --git a/docs/sections/services/dfc/architecture.rst b/docs/sections/services/dfc/architecture.rst
index eec07a9b..f25b855c 100644
--- a/docs/sections/services/dfc/architecture.rst
+++ b/docs/sections/services/dfc/architecture.rst
@@ -13,8 +13,8 @@ found here: `5G bulk PM wiki page`_.
 
 DFC will handle the collection of bulk PM data flow:
     1. Subscribes to fileReady DMaaP topic
-    2. Collects the file from the xNF
-    3. Sends new file data to DataRouter.
+    2. Collects the files from the xNF
+    3. Sends the collected files and files' data to DataRouter.
 
 
 DFC is delivered as one **Docker container** which hosts application server.
diff --git a/docs/sections/services/dfc/configuration.rst b/docs/sections/services/dfc/configuration.rst
index 03999f91..fce00cd9 100644
--- a/docs/sections/services/dfc/configuration.rst
+++ b/docs/sections/services/dfc/configuration.rst
@@ -20,7 +20,7 @@ Configuration file: Config/datafile_endpoints.json
 JSON CONFIGURATION EXPLAINED
 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
 
-Variables of interest (e.g. variables that should be inspected/modifed for a specific runtime environment) are listed below for convenience.  The entire file is provided later in this page for reference.
+Variables of interest (e.g. variables that should be inspected/modified for a specific runtime environment) are listed below for convenience.  The entire file is provided later in this page for reference.
 
 dmaapConsumerConfiguration
 """"""""""""""""""""""""""
diff --git a/docs/sections/services/dfc/consumedapis.rst b/docs/sections/services/dfc/consumedapis.rst
index 2fe63b46..258164a7 100644
--- a/docs/sections/services/dfc/consumedapis.rst
+++ b/docs/sections/services/dfc/consumedapis.rst
@@ -23,7 +23,7 @@ Responses
 +-----------+---------------------+
 
 GET /FEEDLOG_TOPIC/DEFAULT_FEED_ID?type=pub&filename=FILENAME
--------------
+-------------------------------------------------------------
 
 Description
 ~~~~~~~~~~~
diff --git a/docs/sections/services/dfc/delivery.rst b/docs/sections/services/dfc/delivery.rst
index 02494ab2..b08276b9 100644
--- a/docs/sections/services/dfc/delivery.rst
+++ b/docs/sections/services/dfc/delivery.rst
@@ -9,22 +9,21 @@ Docker Container
 
 DFC is delivered as a docker container. The latest released version (Dublin) can be downloaded from nexus:
 
-    ``docker pull nexus3.onap.org:10001/onap/org.onap.dcaegen2.collectors.datafile.datafile-app-server:1.1.2``
+    ``docker pull nexus3.onap.org:10001/onap/org.onap.dcaegen2.collectors.datafile.datafile-app-server:1.1.3``
 
-For another version, it is possible to replace the tag '1.1.2' with any version that seems suitable. Available images
+For another version, it is possible to replace the tag '1.1.3' with any version that seems suitable. Available images
 are visible following this `link`_.
 
-.. _link https://nexus3.onap.org/#browse/search=keyword%3D*datafile*
+.. _link: https://nexus3.onap.org/#browse/search=keyword%3D*collectors.datafile*
 
 
 ONAP Gerrit
 -----------
 
-It is possible to clone the Gerrit repository of DFC with at this `link`_. Choose your preferred settings (ssh, http or
-https, with or without hook) and run the command in your terminal.
-
-.. _link https://gerrit.onap.org/r/#/admin/projects/dcaegen2/collectors/datafile
+It is possible to clone the Gerrit repository of DFC at this
+`link <https://gerrit.onap.org/r/#/admin/projects/dcaegen2/collectors/datafile>`__.
+Choose your preferred settings (ssh, http or https, with or without hook) and run the command in your terminal.
 
 If using Cloudify to deploy DFC, the blueprints are needed, and can be found `here`_.
 
-.. _here https://gerrit.onap.org/r/gitweb?p=dcaegen2/platform/blueprints.git;a=blob;f=blueprints/reference_templates/k8s-datafile-collector.yaml-template;h=17d2aedec131154b4f5f84a08a099b0364b1e627;hb=HEAD
-\ No newline at end of file
+.. _here: https://gerrit.onap.org/r/gitweb?p=dcaegen2/platform/blueprints.git;a=blob;f=blueprints/reference_templates/k8s-datafile-collector.yaml-template;h=17d2aedec131154b4f5f84a08a099b0364b1e627;hb=HEAD
diff --git a/docs/sections/services/dfc/installation.rst b/docs/sections/services/dfc/installation.rst
index d782a522..bfc84e48 100644
--- a/docs/sections/services/dfc/installation.rst
+++ b/docs/sections/services/dfc/installation.rst
@@ -21,25 +21,21 @@ Make sure the Message Router and Data Router are running.
 Deployment steps
 ^^^^^^^^^^^^^^^^
 
-1. Execute bash on the cloudify manager kubernetes pod. 
+1. Execute bash on the cloudify manager kubernetes pod.
 
-.. code-block:: json
-    kubectl -n onap exec -it <dev-dcaegen2-dcae-cloudify-manager> bash
+    ``kubectl -n onap exec -it <dev-dcaegen2-dcae-cloudify-manager> bash``
 
 2. Download the dfc `blueprint`_.
-.. _blueprint 
 
-    https://gerrit.onap.org/r/gitweb?p=dcaegen2/platform/blueprints.git;a=blob;f=blueprints/reference_templates/k8s-datafile-collector.yaml-template;h=17d2aedec131154b4f5f84a08a099b0364b1e627;hb=HEAD
+.. _blueprint: https://gerrit.onap.org/r/gitweb?p=dcaegen2/platform/blueprints.git;a=blob;f=blueprints/reference_templates/k8s-datafile-collector.yaml-template;h=17d2aedec131154b4f5f84a08a099b0364b1e627;hb=HEAD
 
 3. Run Cloudify Install command to install dfc.
 
-.. code-block:: json
-    cfy install <dfc-blueprint-path>
+    ``cfy install <dfc-blueprint-path>``
 
 Sample output:
 
-..code-block:: json
-    cfy install k8s-datafile.yaml
+    ``cfy install k8s-datafile.yaml``
 
 Run '*cfy events list -e 37da3f5f-a06b-4ce8-84d3-8b64ccd81c33'* to retrieve the execution's events/logs.
 
@@ -61,18 +57,17 @@ subscribes to DMAAP/MR fileReady event as JSON messages and publishes the downlo
 Installation
 ^^^^^^^^^^^^
 
-The following command will download the Dublin version of the datafile container from
+The following command will download the Dublin version of the datafile image from
 nexus and launch it in the container named "datafile":
 
-    ``docker run -d -p 8100:8100 -p 8433:8433
-    nexus3.onap.org:10001/onap/org.onap.dcaegen2.collectors.datafile.datafile-app-server:1.1.2``
+    ``docker run -d -p 8100:8100 -p 8433:8433 nexus3.onap.org:10001/onap/org.onap.dcaegen2.collectors.datafile.datafile-app-server:1.1.3``
 
-For another version, it is possible to replace the tag '1.1.2' with any version that seems suitable (including latest).
+For another version, it is possible to replace the tag '1.1.3' with any version that seems suitable (including latest).
 Available images are visible following this `link`_.
 
-.. _link https://nexus3.onap.org/#browse/search=keyword%3D*datafile*
+.. _link: https://nexus3.onap.org/#browse/search=keyword%3D*datafile*
 
-Another option is to pull the container first, and then run it with the image ID:
+Another option is to pull the image first, and then run the image's container with the image ID:
 
     ``docker pull nexus3.onap.org:10001/onap/org.onap.dcaegen2.collectors.datafile.datafile-app-server:latest``
 
diff --git a/docs/sections/services/dfc/release-notes.rst b/docs/sections/services/dfc/release-notes.rst
index 1ae888a2..a0277d80 100644
--- a/docs/sections/services/dfc/release-notes.rst
+++ b/docs/sections/services/dfc/release-notes.rst
@@ -4,11 +4,9 @@
 Release Notes
 =============
 
-Version 1.1.2
+Version 1.1.3
 -------------
 
-:Release Date: 2019-05-30
-
 Messages are now handled in parallel
 
 Retry mechanism implemented
@@ -17,6 +15,8 @@ Adapting to ONAP logging standard
 
 Deployment using Cloudify made available
 
+Bug fix: Too old files (thus not existing anymore) are ignored
+
 
 Version: 1.1.1
 --------------
diff --git a/docs/sections/services/dfc/troubleshooting.rst b/docs/sections/services/dfc/troubleshooting.rst
index c905802b..a4c10a70 100644
--- a/docs/sections/services/dfc/troubleshooting.rst
+++ b/docs/sections/services/dfc/troubleshooting.rst
@@ -1,5 +1,8 @@
-Trobleshooting
-==============
+.. This work is licensed under a Creative Commons Attribution 4.0 International License.
+.. http://creativecommons.org/licenses/by/4.0
+
+Troubleshooting
+===============
 
 In order to find the origin of an error, we suggest to use the logs resulting from tracing, which needs to be activated.
 
@@ -21,27 +24,25 @@ descriptors etc.
 Here are some examples on how to use the REST API  (here curl is used, but a web-browser can also be used. If you are
 logged in to a container, wget can probably be used)  :
 Activate debug tracing on all classes in the DFC:
-.. code-block:: json
-    curl http://127.0.0.1:8100/actuator/loggers/org.onap.dcaegen2.collectors.datafile -i -X POST  -H 'Content-Type:
-    application/json' -d '{"configuredLevel":"debug"}'
+
+    ``curl http://127.0.0.1:8100/actuator/loggers/org.onap.dcaegen2.collectors.datafile -i -X POST  -H 'Content-Type:
+    application/json' -d '{"configuredLevel":"debug"}'``
 
 Read the log file:
-.. code-block:: json
-    curl http://127.0.0.1:8100/actuator/logfile  -i -X GET
+
+    ``curl http://127.0.0.1:8100/actuator/logfile  -i -X GET``
 
 Get build information:
-.. code-block:: json
-    curl http://127.0.0.1:8100/actuator/info
+
+    ``curl http://127.0.0.1:8100/actuator/info``
 
 Get metric from the JVM. This lists the metrics that are available:
 
-.. code-block:: json
-    curl http://127.0.0.1:8100/actuator/metrics  -i -X GET
+    ``curl http://127.0.0.1:8100/actuator/metrics  -i -X GET``
 
 To see the value of a particular metric, just add \/[nameOfTheMetric] in the end of address, for example:
 
-.. code-block:: json
-    curl http://127.0.0.1:8100/actuator/metrics/process.cpu.usage  -i -X GET
+    ``curl http://127.0.0.1:8100/actuator/metrics/process.cpu.usage  -i -X GET``
 
 
 Certificate failure
@@ -50,14 +51,12 @@ Certificate failure
 If there is an error linked to the certificate, it is possible to get information about it. A possible cause for the
 error can be that the expiry date of the certificate is past.
 
-.. code-block:: json
-    keytool -list -v -keystore dfc.jks
+    ``keytool -list -v -keystore dfc.jks``
 
 The command to encode the b64 jks file to local execution is (the \*.jks.b64 is in the repo and the Dockerfile is
 encoding it into .jks. So when you pull from nexus, this won't be needed, only when git-checkout and java/mvn run):
 
-.. code-block:: json
-    base64 -d dfc.jks.b64 > dfc.jks
+    ``base64 -d dfc.jks.b64 > dfc.jks``
 
 
 Common logs due to configuration errors
@@ -67,168 +66,210 @@ Common logs due to configuration errors
 
 
 
-..**Missing configuration on Consul**
+.. **Missing configuration on Consul**
 
-.."Exception during getting configuration from CONSUL/CONFIG_BINDING_SERVICE"
+.. "Exception during getting configuration from CONSUL/CONFIG_BINDING_SERVICE"
 
 
 The file datafile_endpoints.json allows to set different configuration parameters. You can find below the kind of reply
 you get if any parameter is not valid:
 
 
-Wrong trustedCaPassword:
-org.onap.dcaegen2.collectors.datafile.tasks.FileCollector     |2019-04-24T14:05:54.494Z     |WARN     |Failed to download file: PNF0 A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
-\...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     ...
-\...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     ...
-\...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     ...
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:06:40.609Z     |ERROR     |File fetching failed, fileData
-
-
-Wrong trustedCa:
-org.onap.dcaegen2.collectors.datafile.tasks.FileCollector     |2019-04-24T14:11:22.584Z     |WARN     |Failed to download file: PNF0 A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: **WRONGconfig/ftp.jks**     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
-\...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: WRONGconfig/ftp.jks     ...
-\...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: WRONGconfig/ftp.jks     ...
-\...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: WRONGconfig/ftp.jks     ...
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:11:58.963Z     |ERROR     |File fetching failed, fileData
-
-Wrong keyPassword:
-org.onap.dcaegen2.collectors.datafile.tasks.FileCollector     |2019-04-24T14:15:40.694Z     |WARN     |Failed to download file: PNF0 A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
-\...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     ...
-\...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     ...
-\...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     ...
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:16:08.292Z     |ERROR     |File fetching failed, fileData
-
-Wrong keyCert:
-org.onap.dcaegen2.collectors.datafile.tasks.FileCollector     |2019-04-24T14:20:46.308Z     |WARN     |Failed to download file: PNF0 A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: **WRONGconfig/dfc.jks (No such file or directory)**     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
-\...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: WRONGconfig/dfc.jks (No such file or directory)     ...
-\...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: WRONGconfig/dfc.jks (No such file or directory)     ...
-\...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: WRONGconfig/dfc.jks (No such file or directory)     ...
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:21:16.447Z     |ERROR     |File fetching failed, fileData
-
-Wrong consumer dmaapHostName:
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:27:06.578Z     |ERROR     |Polling for file ready message failed, exception: java.net.UnknownHostException: **WRONGlocalhost**: Try again, config: DmaapConsumerConfiguration{consumerId=C12, consumerGroup=OpenDcae-c12, timeoutMs=-1, messageLimit=1, **dmaapHostName=WRONGlocalhost**, dmaapPortNumber=2222, dmaapTopicName=/events/unauthenticated.VES_NOTIFICATION_OUTPUT, dmaapProtocol=http, dmaapUserName=, dmaapUserPassword=, dmaapContentType=application/json, trustStorePath=change it, trustStorePasswordPath=change it, keyStorePath=change it, keyStorePasswordPath=change it, enableDmaapCertAuth=false}     |RequestID=90fe7450-0bc2-4bf6-a2f0-2aeef6f196ae     |     |     |reactor-http-epoll-3     |
-\...     |ERROR     |Polling for file ready message failed, exception: java.net.UnknownHostException: *WRONGlocalhost*, config: DmaapConsumerConfiguration{..., dmaapHostName=*WRONGlocalhost*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.net.UnknownHostException: *WRONGlocalhost*: Try again, config: DmaapConsumerConfiguration{..., dmaapHostName=*WRONGlocalhost*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.net.UnknownHostException: *WRONGlocalhost*: Try again, config: DmaapConsumerConfiguration{..., dmaapHostName=*WRONGlocalhost*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.net.UnknownHostException: *WRONGlocalhost*: Try again, config: DmaapConsumerConfiguration{..., dmaapHostName=*WRONGlocalhost*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.net.UnknownHostException: *WRONGlocalhost*: Try again, config: DmaapConsumerConfiguration{..., dmaapHostName=*WRONGlocalhost*, ...}     ...
-
-Wrong consumer dmaapPortNumber:
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:33:35.286Z     |ERROR     |Polling for file ready message failed, exception: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: localhost/127.0.0.1:**WRONGport**, config: DmaapConsumerConfiguration{consumerId=C12, consumerGroup=OpenDcae-c12, timeoutMs=-1, messageLimit=1, dmaapHostName=localhost, **dmaapPortNumber=WRONGport**, dmaapTopicName=/events/unauthenticated.VES_NOTIFICATION_OUTPUT, dmaapProtocol=http, dmaapUserName=, dmaapUserPassword=, dmaapContentType=application/json, trustStorePath=change it, trustStorePasswordPath=change it, keyStorePath=change it, keyStorePasswordPath=change it, enableDmaapCertAuth=false}     |RequestID=b57c68fe-84bf-442f-accd-ea821a5a321f     |     |     |reactor-http-epoll-3     |
-\...     |ERROR     |Polling for file ready message failed, exception: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: localhost/127.0.0.1:*WRONGport*, config: DmaapConsumerConfiguration{..., dmaapPortNumber=*WRONGport*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: localhost/127.0.0.1:*WRONGport*, config: DmaapConsumerConfiguration{..., dmaapPortNumber=*WRONGport*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: localhost/127.0.0.1:*WRONGport*, config: DmaapConsumerConfiguration{..., dmaapPortNumber=*WRONGport*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: localhost/127.0.0.1:*WRONGport*, config: DmaapConsumerConfiguration{..., dmaapPortNumber=*WRONGport*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: localhost/127.0.0.1:*WRONGport*, config: DmaapConsumerConfiguration{..., dmaapPortNumber=*WRONGport*, ...}     ...
-
-Wrong consumer dmaapTopicName:
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:38:07.097Z     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=C12, consumerGroup=OpenDcae-c12, timeoutMs=-1, messageLimit=1, dmaapHostName=localhost, dmaapPortNumber=2222, **dmaapTopicName=/events/unauthenticated.VES_NOTIFICATION_OUTPUTWRONG**, dmaapProtocol=http, dmaapUserName=, dmaapUserPassword=, dmaapContentType=application/json, trustStorePath=change it, trustStorePasswordPath=change it, keyStorePath=change it, keyStorePasswordPath=change it, enableDmaapCertAuth=false}     |RequestID=8bd71bac-68af-494b-9518-3ab4478371cf     |     |     |reactor-http-epoll-4     |
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., dmaapTopicName=*/events/unauthenticated.VES_NOTIFICATION_OUTPUTWRONG*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., dmaapTopicName=*/events/unauthenticated.VES_NOTIFICATION_OUTPUTWRONG*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., dmaapTopicName=*/events/unauthenticated.VES_NOTIFICATION_OUTPUTWRONG*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., dmaapTopicName=*/events/unauthenticated.VES_NOTIFICATION_OUTPUTWRONG*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., dmaapTopicName=*/events/unauthenticated.VES_NOTIFICATION_OUTPUTWRONG*, ...}     ...
-
-Consumer dmaapProtocol:
+-Wrong trustedCaPassword:
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.tasks.FileCollector     |2019-04-24T14:05:54.494Z     |WARN     |Failed to download file: PNF0 A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
+    \...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     ...
+    \...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     ...
+    \...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     ...
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:06:40.609Z     |ERROR     |File fetching failed, fileData
+
+
+-Wrong trustedCa:
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.tasks.FileCollector     |2019-04-24T14:11:22.584Z     |WARN     |Failed to download file: PNF0 A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: **WRONGconfig/ftp.jks**     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
+    \...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: WRONGconfig/ftp.jks     ...
+    \...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: WRONGconfig/ftp.jks     ...
+    \...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: WRONGconfig/ftp.jks     ...
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:11:58.963Z     |ERROR     |File fetching failed, fileData
+
+-Wrong keyPassword:
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.tasks.FileCollector     |2019-04-24T14:15:40.694Z     |WARN     |Failed to download file: PNF0 A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
+    \...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     ...
+    \...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     ...
+    \...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.IOException: Keystore was tampered with, or password was incorrect     ...
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:16:08.292Z     |ERROR     |File fetching failed, fileData
+
+-Wrong keyCert:
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.tasks.FileCollector     |2019-04-24T14:20:46.308Z     |WARN     |Failed to download file: PNF0 A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: **WRONGconfig/dfc.jks (No such file or directory)**     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
+    \...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: WRONGconfig/dfc.jks (No such file or directory)     ...
+    \...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: WRONGconfig/dfc.jks (No such file or directory)     ...
+    \...     |WARN     |Failed to download file: ..., reason: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Could not open connection: java.io.FileNotFoundException: WRONGconfig/dfc.jks (No such file or directory)     ...
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:21:16.447Z     |ERROR     |File fetching failed, fileData
+
+-Wrong consumer dmaapHostName:
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:27:06.578Z     |ERROR     |Polling for file ready message failed, exception: java.net.UnknownHostException: **WRONGlocalhost**: Try again, config: DmaapConsumerConfiguration{consumerId=C12, consumerGroup=OpenDcae-c12, timeoutMs=-1, messageLimit=1, **dmaapHostName=WRONGlocalhost**, dmaapPortNumber=2222, dmaapTopicName=/events/unauthenticated.VES_NOTIFICATION_OUTPUT, dmaapProtocol=http, dmaapUserName=, dmaapUserPassword=, dmaapContentType=application/json, trustStorePath=change it, trustStorePasswordPath=change it, keyStorePath=change it, keyStorePasswordPath=change it, enableDmaapCertAuth=false}     |RequestID=90fe7450-0bc2-4bf6-a2f0-2aeef6f196ae     |     |     |reactor-http-epoll-3     |
+    \...     |ERROR     |Polling for file ready message failed, exception: java.net.UnknownHostException: *WRONGlocalhost*, config: DmaapConsumerConfiguration{..., dmaapHostName=*WRONGlocalhost*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.net.UnknownHostException: *WRONGlocalhost*: Try again, config: DmaapConsumerConfiguration{..., dmaapHostName=*WRONGlocalhost*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.net.UnknownHostException: *WRONGlocalhost*: Try again, config: DmaapConsumerConfiguration{..., dmaapHostName=*WRONGlocalhost*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.net.UnknownHostException: *WRONGlocalhost*: Try again, config: DmaapConsumerConfiguration{..., dmaapHostName=*WRONGlocalhost*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.net.UnknownHostException: *WRONGlocalhost*: Try again, config: DmaapConsumerConfiguration{..., dmaapHostName=*WRONGlocalhost*, ...}     ...
+
+-Wrong consumer dmaapPortNumber:
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:33:35.286Z     |ERROR     |Polling for file ready message failed, exception: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: localhost/127.0.0.1:**WRONGport**, config: DmaapConsumerConfiguration{consumerId=C12, consumerGroup=OpenDcae-c12, timeoutMs=-1, messageLimit=1, dmaapHostName=localhost, **dmaapPortNumber=WRONGport**, dmaapTopicName=/events/unauthenticated.VES_NOTIFICATION_OUTPUT, dmaapProtocol=http, dmaapUserName=, dmaapUserPassword=, dmaapContentType=application/json, trustStorePath=change it, trustStorePasswordPath=change it, keyStorePath=change it, keyStorePasswordPath=change it, enableDmaapCertAuth=false}     |RequestID=b57c68fe-84bf-442f-accd-ea821a5a321f     |     |     |reactor-http-epoll-3     |
+    \...     |ERROR     |Polling for file ready message failed, exception: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: localhost/127.0.0.1:*WRONGport*, config: DmaapConsumerConfiguration{..., dmaapPortNumber=*WRONGport*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: localhost/127.0.0.1:*WRONGport*, config: DmaapConsumerConfiguration{..., dmaapPortNumber=*WRONGport*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: localhost/127.0.0.1:*WRONGport*, config: DmaapConsumerConfiguration{..., dmaapPortNumber=*WRONGport*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: localhost/127.0.0.1:*WRONGport*, config: DmaapConsumerConfiguration{..., dmaapPortNumber=*WRONGport*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: io.netty.channel.AbstractChannel$AnnotatedConnectException: syscall:getsockopt(..) failed: Connection refused: localhost/127.0.0.1:*WRONGport*, config: DmaapConsumerConfiguration{..., dmaapPortNumber=*WRONGport*, ...}     ...
+
+-Wrong consumer dmaapTopicName:
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T14:38:07.097Z     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=C12, consumerGroup=OpenDcae-c12, timeoutMs=-1, messageLimit=1, dmaapHostName=localhost, dmaapPortNumber=2222, **dmaapTopicName=/events/unauthenticated.VES_NOTIFICATION_OUTPUTWRONG**, dmaapProtocol=http, dmaapUserName=, dmaapUserPassword=, dmaapContentType=application/json, trustStorePath=change it, trustStorePasswordPath=change it, keyStorePath=change it, keyStorePasswordPath=change it, enableDmaapCertAuth=false}     |RequestID=8bd71bac-68af-494b-9518-3ab4478371cf     |     |     |reactor-http-epoll-4     |
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., dmaapTopicName=*/events/unauthenticated.VES_NOTIFICATION_OUTPUTWRONG*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., dmaapTopicName=*/events/unauthenticated.VES_NOTIFICATION_OUTPUTWRONG*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., dmaapTopicName=*/events/unauthenticated.VES_NOTIFICATION_OUTPUTWRONG*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., dmaapTopicName=*/events/unauthenticated.VES_NOTIFICATION_OUTPUTWRONG*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., dmaapTopicName=*/events/unauthenticated.VES_NOTIFICATION_OUTPUTWRONG*, ...}     ...
+
+-Consumer dmaapProtocol:
 Not configurable.
 
-..Wrong consumer dmaapUserName:
-..No issue with the simulator, to be checked in cloud40.
+.. Wrong consumer dmaapUserName:
+.. No issue with the simulator, to be checked in cloud40.
 
-..Wrong consumer dmaapUserPassword:
-..No issue with the simulator, to be checked in cloud40.
+.. Wrong consumer dmaapUserPassword:
+.. No issue with the simulator, to be checked in cloud40.
 
-Consumer dmaapContentType:
+-Consumer dmaapContentType:
 Not configurable.
 
-Wrong consumer consumerId:
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:10:13.485Z     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{**consumerId=C12WRONG**, consumerGroup=OpenDcae-c12, timeoutMs=-1, messageLimit=1, dmaapHostName=localhost, dmaapPortNumber=2222, dmaapTopicName=/events/unauthenticated.VES_NOTIFICATION_OUTPUT, dmaapProtocol=http, dmaapUserName=, dmaapUserPassword=, dmaapContentType=application/json, trustStorePath=change it, trustStorePasswordPath=change it, keyStorePath=change it, keyStorePasswordPath=change it, enableDmaapCertAuth=false}     |RequestID=138acd07-c519-41ef-8dcb-08d78af2d914     |     |     |reactor-http-epoll-4     |
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=*C12WRONG*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=*C12WRONG*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=*C12WRONG*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=*C12WRONG*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=*C12WRONG*, ...}     ...
-
-Wrong consumer consumerGroup:
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:15:51.869Z     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=C12, **consumerGroup=OpenDcae-c12WRONG**, timeoutMs=-1, messageLimit=1, dmaapHostName=localhost, dmaapPortNumber=2222, dmaapTopicName=/events/unauthenticated.VES_NOTIFICATION_OUTPUT, dmaapProtocol=http, dmaapUserName=, dmaapUserPassword=, dmaapContentType=application/json, trustStorePath=change it, trustStorePasswordPath=change it, keyStorePath=change it, keyStorePasswordPath=change it, enableDmaapCertAuth=false}     |RequestID=880c4593-dc3f-422e-b9d7-4aeca8cbd0bf     |     |     |reactor-http-epoll-4     |
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., consumerGroup=*OpenDcae-c12WRONG*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., consumerGroup=*OpenDcae-c12WRONG*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., consumerGroup=*OpenDcae-c12WRONG*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., consumerGroup=*OpenDcae-c12WRONG*, ...}     ...
-\...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., consumerGroup=*OpenDcae-c12WRONG*, ...}     ...
-
-Wrong consumer timeoutMs (not a numeric value):
-org.onap.dcaegen2.collectors.datafile.configuration.AppConfig     |2019-04-24T15:23:04.674Z     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     |RequestID=215c39ed-d54e-44a2-9a10-08539e645801     |java.lang.NumberFormatException: **For input string: "WRONG"**\n\tat java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)\n\tat java.lang.Integer.parseInt(Integer.java:580)\n\tat java.lang.Integer.parseInt(Integer.java:615)\n\tat com.google.gson.JsonPrimitive.getAsInt(JsonPrimitive.java:264)\n\tat com.google.gson.internal.bind.JsonTreeReader.nextInt(JsonTreeReader.java:243)\n\tat com.google.gson.internal.bind.TypeAdapters$7.read(TypeAdapters.java:226)\n\t... 20 common frames omitted\nWrapped by: com.google.gson.JsonSyntaxException: java.lang.NumberFormatException: **For input string: "WRONG"**\n\tat com.google.gson.internal.bind.TypeAdapters$7.read(TypeAdapters.java:228)\n\tat com.google.gson.internal.bind.TypeAdapters$7.read(TypeAdapters.java:218)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.readInTimeoutMs(GsonAdaptersDmaapConsumerConfiguration.java:219)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.eachAttribute(GsonAdaptersDmaapConsumerConfiguration.java:138)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.readDmaapConsumerConfiguration(GsonAdaptersDmaapConsumerConfiguration.java:116)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.read(GsonAdaptersDmaapConsumerConfiguration.java:66)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.read(GsonAdaptersDmaapConsumerConfiguration.java:31)\n\tat com.google.gson.Gson.fromJson(Gson.java:927)\n\tat com.google.gson.Gson.fromJson(Gson.java:994)\n\tat com.google.gson.Gson.fromJson(Gson.java:967)\n\tat org.onap.dcaegen2.collectors.datafile.configuration.AppConfig.deserializeType(AppConfig.java:130)\n\tat org.onap.dcaegen2.collectors.datafile.configuration.AppConfig.loadConfigurationFromFile(AppConfig.java:96)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.executeDatafileMainTask(ScheduledTasks.java:91)\n\tat org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |pool-3-thread-1     |
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:23:04.677Z     |ERROR     |Unexpected exception: java.lang.NullPointerException     |RequestID=215c39ed-d54e-44a2-9a10-08539e645801     |java.lang.NullPointerException: null\n\tat org.onap.dcaegen2.collectors.datafile.service.DmaapWebClient.fromConfiguration(DmaapWebClient.java:54)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DMaaPMessageConsumer.createHttpClient(DMaaPMessageConsumer.java:74)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DMaaPMessageConsumer.<init>(DMaaPMessageConsumer.java:48)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.createConsumerTask(ScheduledTasks.java:157)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.fetchMoreFileReadyMessages(ScheduledTasks.java:247)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.createMainTask(ScheduledTasks.java:108)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.executeDatafileMainTask(ScheduledTasks.java:92)\n\tat org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |pool-3-thread-1     |
-\...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
-\...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
-\...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
-\...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
-\...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
-\...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
-\...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
-\...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
-\...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
-\...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
-
-Wrong consumer messageLimit:
-org.onap.dcaegen2.collectors.datafile.configuration.AppConfig     |2019-04-24T15:27:40.433Z     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     |RequestID=69974429-d80a-4333-a16c-eae7588905a9     |java.lang.NumberFormatException: **For input string: "WRONG"**\n\tat java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)\n\tat java.lang.Integer.parseInt(Integer.java:580)\n\tat java.lang.Integer.parseInt(Integer.java:615)\n\tat com.google.gson.JsonPrimitive.getAsInt(JsonPrimitive.java:264)\n\tat com.google.gson.internal.bind.JsonTreeReader.nextInt(JsonTreeReader.java:243)\n\tat com.google.gson.internal.bind.TypeAdapters$7.read(TypeAdapters.java:226)\n\t... 20 common frames omitted\nWrapped by: com.google.gson.JsonSyntaxException: java.lang.NumberFormatException: **For input string: "WRONG"**\n\tat com.google.gson.internal.bind.TypeAdapters$7.read(TypeAdapters.java:228)\n\tat com.google.gson.internal.bind.TypeAdapters$7.read(TypeAdapters.java:218)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.readInMessageLimit(GsonAdaptersDmaapConsumerConfiguration.java:225)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.eachAttribute(GsonAdaptersDmaapConsumerConfiguration.java:152)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.readDmaapConsumerConfiguration(GsonAdaptersDmaapConsumerConfiguration.java:116)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.read(GsonAdaptersDmaapConsumerConfiguration.java:66)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.read(GsonAdaptersDmaapConsumerConfiguration.java:31)\n\tat com.google.gson.Gson.fromJson(Gson.java:927)\n\tat com.google.gson.Gson.fromJson(Gson.java:994)\n\tat com.google.gson.Gson.fromJson(Gson.java:967)\n\tat org.onap.dcaegen2.collectors.datafile.configuration.AppConfig.deserializeType(AppConfig.java:130)\n\tat org.onap.dcaegen2.collectors.datafile.configuration.AppConfig.loadConfigurationFromFile(AppConfig.java:96)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.executeDatafileMainTask(ScheduledTasks.java:91)\n\tat org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |pool-3-thread-1     |
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:27:40.436Z     |ERROR     |Unexpected exception: java.lang.NullPointerException     |RequestID=69974429-d80a-4333-a16c-eae7588905a9     |java.lang.NullPointerException: null\n\tat org.onap.dcaegen2.collectors.datafile.service.DmaapWebClient.fromConfiguration(DmaapWebClient.java:54)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DMaaPMessageConsumer.createHttpClient(DMaaPMessageConsumer.java:74)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DMaaPMessageConsumer.<init>(DMaaPMessageConsumer.java:48)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.createConsumerTask(ScheduledTasks.java:157)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.fetchMoreFileReadyMessages(ScheduledTasks.java:247)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.createMainTask(ScheduledTasks.java:108)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.executeDatafileMainTask(ScheduledTasks.java:92)\n\tat org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |pool-3-thread-1     |
-\...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
-\...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
-\...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
-\...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
-\...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
-\...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
-\...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
-\...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
-\...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
-\...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
-
-Wrong producer dmaapHostName:
-org.onap.dcaegen2.collectors.datafile.tasks.PublishedChecker     |2019-04-24T15:33:00.097Z     |WARN     |Unable to check if file has been published, file: A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |java.net.UnknownHostException: **WRONGlocalhost**: Try again\n\tat java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)\n\tat java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:929)\n\tat java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1324)\n\tat java.net.InetAddress.getAllByName0(InetAddress.java:1277)\n\tat java.net.InetAddress.getAllByName(InetAddress.java:1193)\n\tat java.net.InetAddress.getAllByName(InetAddress.java:1127)\n\tat org.apache.http.impl.conn.SystemDefaultDnsResolver.resolve(SystemDefaultDnsResolver.java:45)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager$InternalAddressResolver.resolveRemoteAddress(PoolingNHttpClientConnectionManager.java:664)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager$InternalAddressResolver.resolveRemoteAddress(PoolingNHttpClientConnectionManager.java:635)\n\tat org.apache.http.nio.pool.AbstractNIOConnPool.processPendingRequest(AbstractNIOConnPool.java:474)\n\tat org.apache.http.nio.pool.AbstractNIOConnPool.lease(AbstractNIOConnPool.java:280)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.requestConnection(PoolingNHttpClientConnectionManager.java:295)\n\tat org.apache.http.impl.nio.client.AbstractClientExchangeHandler.requestConnection(AbstractClientExchangeHandler.java:377)\n\tat org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.start(DefaultClientExchangeHandlerImpl.java:129)\n\tat org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:141)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:75)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:108)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:92)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:119)\n\t... 23 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: java.net.UnknownHostException: **WRONGlocalhost**: Try again\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:120)\n\t... 23 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:124)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.PublishedChecker.isFilePublished(PublishedChecker.java:82)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.shouldBePublished(ScheduledTasks.java:194)\n\tat reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:93)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:449)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:384)\n\tat reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:924)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)\n\tat reactor.core.publisher.Flux.subscribe(Flux.java:7743)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:398)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:484)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |FileCollectorWorker-2     |
-org.onap.dcaegen2.collectors.datafile.ftp.FtpsClient     |2019-04-24T15:33:00.275Z     |WARN     |Local file /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz already created     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
-org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher     |2019-04-24T15:33:00.429Z     |WARN     |Unable to send file to DataRouter. Data: /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |java.net.UnknownHostException: **WRONGlocalhost**\n\tat java.net.InetAddress.getAllByName0(InetAddress.java:1281)\n\tat java.net.InetAddress.getAllByName(InetAddress.java:1193)\n\tat java.net.InetAddress.getAllByName(InetAddress.java:1127)\n\tat org.apache.http.impl.conn.SystemDefaultDnsResolver.resolve(SystemDefaultDnsResolver.java:45)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager$InternalAddressResolver.resolveRemoteAddress(PoolingNHttpClientConnectionManager.java:664)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager$InternalAddressResolver.resolveRemoteAddress(PoolingNHttpClientConnectionManager.java:635)\n\tat org.apache.http.nio.pool.AbstractNIOConnPool.processPendingRequest(AbstractNIOConnPool.java:474)\n\tat org.apache.http.nio.pool.AbstractNIOConnPool.lease(AbstractNIOConnPool.java:280)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.requestConnection(PoolingNHttpClientConnectionManager.java:295)\n\tat org.apache.http.impl.nio.client.AbstractClientExchangeHandler.requestConnection(AbstractClientExchangeHandler.java:377)\n\tat org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.start(DefaultClientExchangeHandlerImpl.java:129)\n\tat org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:141)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:75)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:108)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:92)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:92)\n\t... 61 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: java.net.UnknownHostException: **WRONGlocalhost**\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:93)\n\t... 61 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:97)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher.publishFile(DataRouterPublisher.java:102)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:118)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:389)\n\tat reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2070)\n\tat reactor.core.publisher.MonoProcessor.onSubscribe(MonoProcessor.java:399)\n\tat reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.MonoProcessor.add(MonoProcessor.java:531)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:444)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:85)\n\tat reactor.core.publisher.MonoRetryWhen.subscribe(MonoRetryWhen.java:50)\n\tat reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:501)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:943)\n\tat reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:73)\n\tat reactor.core.publisher.SerializedSubscriber.onNext(SerializedSubscriber.java:89)\n\tat reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onNext(FluxRetryWhen.java:145)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:389)\n\tat reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2070)\n\tat reactor.core.publisher.MonoProcessor.onSubscribe(MonoProcessor.java:399)\n\tat reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.MonoProcessor.add(MonoProcessor.java:531)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:444)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:85)\n\tat reactor.core.publisher.MonoRetryWhen.subscribe(MonoRetryWhen.java:50)\n\tat reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:449)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:384)\n\tat reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:924)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)\n\tat reactor.core.publisher.Flux.subscribe(Flux.java:7743)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:398)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:484)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |FileCollectorWorker-2     |
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.UnknownHostException: *WRONGlocalhost*\n\tat ... java.net.UnknownHostException: *WRONGlocalhost*\n\tat ... Unable to create web client.\n\tat ...
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.UnknownHostException: *WRONGlocalhost*\n\tat ... java.net.UnknownHostException: *WRONGlocalhost*\n\tat ... Unable to create web client.\n\tat ...
-org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher     |2019-04-24T15:33:18.558Z     |WARN     |Unable to send file to DataRouter. Data: /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |java.net.UnknownHostException: **WRONGlocalhost**: Try again\n\tat java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)\n\tat java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:929)\n\tat java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1324)\n\tat java.net.InetAddress.getAllByName0(InetAddress.java:1277)\n\tat java.net.InetAddress.getAllByName(InetAddress.java:1193)\n\tat java.net.InetAddress.getAllByName(InetAddress.java:1127)\n\tat org.apache.http.impl.conn.SystemDefaultDnsResolver.resolve(SystemDefaultDnsResolver.java:45)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager$InternalAddressResolver.resolveRemoteAddress(PoolingNHttpClientConnectionManager.java:664)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager$InternalAddressResolver.resolveRemoteAddress(PoolingNHttpClientConnectionManager.java:635)\n\tat org.apache.http.nio.pool.AbstractNIOConnPool.processPendingRequest(AbstractNIOConnPool.java:474)\n\tat org.apache.http.nio.pool.AbstractNIOConnPool.lease(AbstractNIOConnPool.java:280)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.requestConnection(PoolingNHttpClientConnectionManager.java:295)\n\tat org.apache.http.impl.nio.client.AbstractClientExchangeHandler.requestConnection(AbstractClientExchangeHandler.java:377)\n\tat org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.start(DefaultClientExchangeHandlerImpl.java:129)\n\tat org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:141)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:75)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:108)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:92)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:92)\n\t... 20 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: java.net.UnknownHostException: **WRONGlocalhost**: Try again\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:93)\n\t... 20 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:97)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher.publishFile(DataRouterPublisher.java:102)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:118)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:457)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.resubscribe(FluxRetryWhen.java:183)\n\tat reactor.core.publisher.FluxRetryWhen$RetryWhenOtherSubscriber.onNext(FluxRetryWhen.java:229)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:501)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:943)\n\tat reactor.core.publisher.MonoDelay$MonoDelayRunnable.run(MonoDelay.java:117)\n\tat reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:50)\n\tat reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:27)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |parallel-204     |
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.UnknownHostException: *WRONGlocalhost*\n\tat ... java.net.UnknownHostException: *WRONGlocalhost*\n\tat ... Unable to create web client.\n\tat ...
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.UnknownHostException: *WRONGlocalhost*: Try again\n\tat ... java.net.UnknownHostException: *WRONGlocalhost*: Try again\n\tat ... Unable to create web client.\n\tat ...
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:33:57.340Z     |ERROR     |File publishing failed: FilePublishInformation{productName=RnNode, vendorName=Ericsson, lastEpochMicrosec=8745745764578, sourceName=PNF0, startEpochMicrosec=8745745764578, timeZoneOffset=UTC+05.30, name=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, location=ftps://onap:pano@localhost:21/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, internalLocation=/tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10, context={RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz}}     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |parallel-206     |
-
-Wrong producer dmaapPortNumber:
-org.onap.dcaegen2.collectors.datafile.tasks.PublishedChecker     |2019-04-24T15:38:24.806Z     |WARN     |Unable to check if file has been published, file: A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |java.net.ConnectException: Connection refused\n\tat sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\n\tat sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)\n\tat org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:171)\n\tat org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:145)\n\tat org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:348)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\n\t... 1 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: java.net.ConnectException: Connection refused\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:120)\n\t... 23 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:124)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.PublishedChecker.isFilePublished(PublishedChecker.java:82)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.shouldBePublished(ScheduledTasks.java:194)\n\tat reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:93)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:449)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:384)\n\tat reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:924)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)\n\tat reactor.core.publisher.Flux.subscribe(Flux.java:7743)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:398)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:484)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |FileCollectorWorker-2     |
-org.onap.dcaegen2.collectors.datafile.ftp.FtpsClient     |2019-04-24T15:38:24.972Z     |WARN     |Local file /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz already created     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
-org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher     |2019-04-24T15:38:25.146Z     |WARN     |Unable to send file to DataRouter. Data: /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |java.net.ConnectException: Connection refused\n\tat sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\n\tat sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)\n\tat org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:171)\n\tat org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:145)\n\tat org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:348)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\n\t... 1 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: java.net.ConnectException: Connection refused\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:93)\n\t... 61 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:97)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher.publishFile(DataRouterPublisher.java:102)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:118)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:389)\n\tat reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2070)\n\tat reactor.core.publisher.MonoProcessor.onSubscribe(MonoProcessor.java:399)\n\tat reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.MonoProcessor.add(MonoProcessor.java:531)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:444)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:85)\n\tat reactor.core.publisher.MonoRetryWhen.subscribe(MonoRetryWhen.java:50)\n\tat reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:501)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:943)\n\tat reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:73)\n\tat reactor.core.publisher.SerializedSubscriber.onNext(SerializedSubscriber.java:89)\n\tat reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onNext(FluxRetryWhen.java:145)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:389)\n\tat reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2070)\n\tat reactor.core.publisher.MonoProcessor.onSubscribe(MonoProcessor.java:399)\n\tat reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.MonoProcessor.add(MonoProcessor.java:531)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:444)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:85)\n\tat reactor.core.publisher.MonoRetryWhen.subscribe(MonoRetryWhen.java:50)\n\tat reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:449)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:384)\n\tat reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:924)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)\n\tat reactor.core.publisher.Flux.subscribe(Flux.java:7743)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:398)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:484)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |FileCollectorWorker-2     |
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.ConnectException: Connection refused\n\tat ... Connection refused\n\tat ... Unable to create web client.\n\tat ...
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.ConnectException: Connection refused\n\tat ... Connection refused\n\tat ... Unable to create web client.\n\tat ...
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.ConnectException: Connection refused\n\tat ... Connection refused\n\tat ... Unable to create web client.\n\tat ...
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.ConnectException: Connection refused\n\tat ... Connection refused\n\tat ... Unable to create web client.\n\tat ...
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.ConnectException: Connection refused\n\tat ... Connection refused\n\tat ... Unable to create web client.\n\tat ...
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:39:38.121Z     |ERROR     |File publishing failed: FilePublishInformation{productName=RnNode, vendorName=Ericsson, lastEpochMicrosec=8745745764578, sourceName=PNF0, startEpochMicrosec=8745745764578, timeZoneOffset=UTC+05.30, name=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, location=ftps://onap:pano@localhost:21/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, internalLocation=/tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10, context={RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz}}     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |parallel-206     |
-
-Producer dmaapTopicName:
+-Wrong consumer consumerId:
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:10:13.485Z     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{**consumerId=C12WRONG**, consumerGroup=OpenDcae-c12, timeoutMs=-1, messageLimit=1, dmaapHostName=localhost, dmaapPortNumber=2222, dmaapTopicName=/events/unauthenticated.VES_NOTIFICATION_OUTPUT, dmaapProtocol=http, dmaapUserName=, dmaapUserPassword=, dmaapContentType=application/json, trustStorePath=change it, trustStorePasswordPath=change it, keyStorePath=change it, keyStorePasswordPath=change it, enableDmaapCertAuth=false}     |RequestID=138acd07-c519-41ef-8dcb-08d78af2d914     |     |     |reactor-http-epoll-4     |
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=*C12WRONG*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=*C12WRONG*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=*C12WRONG*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=*C12WRONG*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=*C12WRONG*, ...}     ...
+
+-Wrong consumer consumerGroup:
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:15:51.869Z     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{consumerId=C12, **consumerGroup=OpenDcae-c12WRONG**, timeoutMs=-1, messageLimit=1, dmaapHostName=localhost, dmaapPortNumber=2222, dmaapTopicName=/events/unauthenticated.VES_NOTIFICATION_OUTPUT, dmaapProtocol=http, dmaapUserName=, dmaapUserPassword=, dmaapContentType=application/json, trustStorePath=change it, trustStorePasswordPath=change it, keyStorePath=change it, keyStorePasswordPath=change it, enableDmaapCertAuth=false}     |RequestID=880c4593-dc3f-422e-b9d7-4aeca8cbd0bf     |     |     |reactor-http-epoll-4     |
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., consumerGroup=*OpenDcae-c12WRONG*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., consumerGroup=*OpenDcae-c12WRONG*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., consumerGroup=*OpenDcae-c12WRONG*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., consumerGroup=*OpenDcae-c12WRONG*, ...}     ...
+    \...     |ERROR     |Polling for file ready message failed, exception: java.lang.RuntimeException: DmaaPConsumer HTTP 404 NOT_FOUND, config: DmaapConsumerConfiguration{..., consumerGroup=*OpenDcae-c12WRONG*, ...}     ...
+
+-Wrong consumer timeoutMs (not a numeric value):
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.configuration.AppConfig     |2019-04-24T15:23:04.674Z     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     |RequestID=215c39ed-d54e-44a2-9a10-08539e645801     |java.lang.NumberFormatException: **For input string: "WRONG"**\n\tat java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)\n\tat java.lang.Integer.parseInt(Integer.java:580)\n\tat java.lang.Integer.parseInt(Integer.java:615)\n\tat com.google.gson.JsonPrimitive.getAsInt(JsonPrimitive.java:264)\n\tat com.google.gson.internal.bind.JsonTreeReader.nextInt(JsonTreeReader.java:243)\n\tat com.google.gson.internal.bind.TypeAdapters$7.read(TypeAdapters.java:226)\n\t... 20 common frames omitted\nWrapped by: com.google.gson.JsonSyntaxException: java.lang.NumberFormatException: **For input string: "WRONG"**\n\tat com.google.gson.internal.bind.TypeAdapters$7.read(TypeAdapters.java:228)\n\tat com.google.gson.internal.bind.TypeAdapters$7.read(TypeAdapters.java:218)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.readInTimeoutMs(GsonAdaptersDmaapConsumerConfiguration.java:219)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.eachAttribute(GsonAdaptersDmaapConsumerConfiguration.java:138)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.readDmaapConsumerConfiguration(GsonAdaptersDmaapConsumerConfiguration.java:116)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.read(GsonAdaptersDmaapConsumerConfiguration.java:66)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.read(GsonAdaptersDmaapConsumerConfiguration.java:31)\n\tat com.google.gson.Gson.fromJson(Gson.java:927)\n\tat com.google.gson.Gson.fromJson(Gson.java:994)\n\tat com.google.gson.Gson.fromJson(Gson.java:967)\n\tat org.onap.dcaegen2.collectors.datafile.configuration.AppConfig.deserializeType(AppConfig.java:130)\n\tat org.onap.dcaegen2.collectors.datafile.configuration.AppConfig.loadConfigurationFromFile(AppConfig.java:96)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.executeDatafileMainTask(ScheduledTasks.java:91)\n\tat org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |pool-3-thread-1     |
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:23:04.677Z     |ERROR     |Unexpected exception: java.lang.NullPointerException     |RequestID=215c39ed-d54e-44a2-9a10-08539e645801     |java.lang.NullPointerException: null\n\tat org.onap.dcaegen2.collectors.datafile.service.DmaapWebClient.fromConfiguration(DmaapWebClient.java:54)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DMaaPMessageConsumer.createHttpClient(DMaaPMessageConsumer.java:74)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DMaaPMessageConsumer.<init>(DMaaPMessageConsumer.java:48)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.createConsumerTask(ScheduledTasks.java:157)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.fetchMoreFileReadyMessages(ScheduledTasks.java:247)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.createMainTask(ScheduledTasks.java:108)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.executeDatafileMainTask(ScheduledTasks.java:92)\n\tat org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |pool-3-thread-1     |
+    \...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
+    \...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
+    \...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
+    \...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
+    \...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
+    \...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
+    \...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
+    \...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
+    \...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
+    \...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
+
+-Wrong consumer messageLimit:
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.configuration.AppConfig     |2019-04-24T15:27:40.433Z     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     |RequestID=69974429-d80a-4333-a16c-eae7588905a9     |java.lang.NumberFormatException: **For input string: "WRONG"**\n\tat java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)\n\tat java.lang.Integer.parseInt(Integer.java:580)\n\tat java.lang.Integer.parseInt(Integer.java:615)\n\tat com.google.gson.JsonPrimitive.getAsInt(JsonPrimitive.java:264)\n\tat com.google.gson.internal.bind.JsonTreeReader.nextInt(JsonTreeReader.java:243)\n\tat com.google.gson.internal.bind.TypeAdapters$7.read(TypeAdapters.java:226)\n\t... 20 common frames omitted\nWrapped by: com.google.gson.JsonSyntaxException: java.lang.NumberFormatException: **For input string: "WRONG"**\n\tat com.google.gson.internal.bind.TypeAdapters$7.read(TypeAdapters.java:228)\n\tat com.google.gson.internal.bind.TypeAdapters$7.read(TypeAdapters.java:218)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.readInMessageLimit(GsonAdaptersDmaapConsumerConfiguration.java:225)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.eachAttribute(GsonAdaptersDmaapConsumerConfiguration.java:152)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.readDmaapConsumerConfiguration(GsonAdaptersDmaapConsumerConfiguration.java:116)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.read(GsonAdaptersDmaapConsumerConfiguration.java:66)\n\tat org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.GsonAdaptersDmaapConsumerConfiguration$DmaapConsumerConfigurationTypeAdapter.read(GsonAdaptersDmaapConsumerConfiguration.java:31)\n\tat com.google.gson.Gson.fromJson(Gson.java:927)\n\tat com.google.gson.Gson.fromJson(Gson.java:994)\n\tat com.google.gson.Gson.fromJson(Gson.java:967)\n\tat org.onap.dcaegen2.collectors.datafile.configuration.AppConfig.deserializeType(AppConfig.java:130)\n\tat org.onap.dcaegen2.collectors.datafile.configuration.AppConfig.loadConfigurationFromFile(AppConfig.java:96)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.executeDatafileMainTask(ScheduledTasks.java:91)\n\tat org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |pool-3-thread-1     |
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:27:40.436Z     |ERROR     |Unexpected exception: java.lang.NullPointerException     |RequestID=69974429-d80a-4333-a16c-eae7588905a9     |java.lang.NullPointerException: null\n\tat org.onap.dcaegen2.collectors.datafile.service.DmaapWebClient.fromConfiguration(DmaapWebClient.java:54)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DMaaPMessageConsumer.createHttpClient(DMaaPMessageConsumer.java:74)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DMaaPMessageConsumer.<init>(DMaaPMessageConsumer.java:48)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.createConsumerTask(ScheduledTasks.java:157)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.fetchMoreFileReadyMessages(ScheduledTasks.java:247)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.createMainTask(ScheduledTasks.java:108)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.executeDatafileMainTask(ScheduledTasks.java:92)\n\tat org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |pool-3-thread-1     |
+    \...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
+    \...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
+    \...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
+    \...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
+    \...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
+    \...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
+    \...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
+    \...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
+    \...configuration.AppConfig     ...     |ERROR     |Problem with loading configuration, file: /opt/app/datafile/config/datafile_endpoints.json     ...     |java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ... java.lang.NumberFormatException: For input string: *"WRONG"*\n\tat ...
+    \...tasks.ScheduledTasks     ...     |ERROR     |Unexpected exception: java.lang.NullPointerException     ...
+
+-Wrong producer dmaapHostName:
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.tasks.PublishedChecker     |2019-04-24T15:33:00.097Z     |WARN     |Unable to check if file has been published, file: A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |java.net.UnknownHostException: **WRONGlocalhost**: Try again\n\tat java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)\n\tat java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:929)\n\tat java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1324)\n\tat java.net.InetAddress.getAllByName0(InetAddress.java:1277)\n\tat java.net.InetAddress.getAllByName(InetAddress.java:1193)\n\tat java.net.InetAddress.getAllByName(InetAddress.java:1127)\n\tat org.apache.http.impl.conn.SystemDefaultDnsResolver.resolve(SystemDefaultDnsResolver.java:45)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager$InternalAddressResolver.resolveRemoteAddress(PoolingNHttpClientConnectionManager.java:664)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager$InternalAddressResolver.resolveRemoteAddress(PoolingNHttpClientConnectionManager.java:635)\n\tat org.apache.http.nio.pool.AbstractNIOConnPool.processPendingRequest(AbstractNIOConnPool.java:474)\n\tat org.apache.http.nio.pool.AbstractNIOConnPool.lease(AbstractNIOConnPool.java:280)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.requestConnection(PoolingNHttpClientConnectionManager.java:295)\n\tat org.apache.http.impl.nio.client.AbstractClientExchangeHandler.requestConnection(AbstractClientExchangeHandler.java:377)\n\tat org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.start(DefaultClientExchangeHandlerImpl.java:129)\n\tat org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:141)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:75)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:108)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:92)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:119)\n\t... 23 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: java.net.UnknownHostException: **WRONGlocalhost**: Try again\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:120)\n\t... 23 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:124)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.PublishedChecker.isFilePublished(PublishedChecker.java:82)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.shouldBePublished(ScheduledTasks.java:194)\n\tat reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:93)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:449)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:384)\n\tat reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:924)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)\n\tat reactor.core.publisher.Flux.subscribe(Flux.java:7743)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:398)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:484)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |FileCollectorWorker-2     |
+    org.onap.dcaegen2.collectors.datafile.ftp.FtpsClient     |2019-04-24T15:33:00.275Z     |WARN     |Local file /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz already created     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
+    org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher     |2019-04-24T15:33:00.429Z     |WARN     |Unable to send file to DataRouter. Data: /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |java.net.UnknownHostException: **WRONGlocalhost**\n\tat java.net.InetAddress.getAllByName0(InetAddress.java:1281)\n\tat java.net.InetAddress.getAllByName(InetAddress.java:1193)\n\tat java.net.InetAddress.getAllByName(InetAddress.java:1127)\n\tat org.apache.http.impl.conn.SystemDefaultDnsResolver.resolve(SystemDefaultDnsResolver.java:45)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager$InternalAddressResolver.resolveRemoteAddress(PoolingNHttpClientConnectionManager.java:664)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager$InternalAddressResolver.resolveRemoteAddress(PoolingNHttpClientConnectionManager.java:635)\n\tat org.apache.http.nio.pool.AbstractNIOConnPool.processPendingRequest(AbstractNIOConnPool.java:474)\n\tat org.apache.http.nio.pool.AbstractNIOConnPool.lease(AbstractNIOConnPool.java:280)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.requestConnection(PoolingNHttpClientConnectionManager.java:295)\n\tat org.apache.http.impl.nio.client.AbstractClientExchangeHandler.requestConnection(AbstractClientExchangeHandler.java:377)\n\tat org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.start(DefaultClientExchangeHandlerImpl.java:129)\n\tat org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:141)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:75)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:108)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:92)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:92)\n\t... 61 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: java.net.UnknownHostException: **WRONGlocalhost**\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:93)\n\t... 61 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:97)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher.publishFile(DataRouterPublisher.java:102)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:118)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:389)\n\tat reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2070)\n\tat reactor.core.publisher.MonoProcessor.onSubscribe(MonoProcessor.java:399)\n\tat reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.MonoProcessor.add(MonoProcessor.java:531)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:444)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:85)\n\tat reactor.core.publisher.MonoRetryWhen.subscribe(MonoRetryWhen.java:50)\n\tat reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:501)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:943)\n\tat reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:73)\n\tat reactor.core.publisher.SerializedSubscriber.onNext(SerializedSubscriber.java:89)\n\tat reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onNext(FluxRetryWhen.java:145)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:389)\n\tat reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2070)\n\tat reactor.core.publisher.MonoProcessor.onSubscribe(MonoProcessor.java:399)\n\tat reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.MonoProcessor.add(MonoProcessor.java:531)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:444)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:85)\n\tat reactor.core.publisher.MonoRetryWhen.subscribe(MonoRetryWhen.java:50)\n\tat reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:449)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:384)\n\tat reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:924)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)\n\tat reactor.core.publisher.Flux.subscribe(Flux.java:7743)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:398)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:484)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |FileCollectorWorker-2     |
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.UnknownHostException: *WRONGlocalhost*\n\tat ... java.net.UnknownHostException: *WRONGlocalhost*\n\tat ... Unable to create web client.\n\tat ...
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.UnknownHostException: *WRONGlocalhost*\n\tat ... java.net.UnknownHostException: *WRONGlocalhost*\n\tat ... Unable to create web client.\n\tat ...
+    org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher     |2019-04-24T15:33:18.558Z     |WARN     |Unable to send file to DataRouter. Data: /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |java.net.UnknownHostException: **WRONGlocalhost**: Try again\n\tat java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)\n\tat java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:929)\n\tat java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1324)\n\tat java.net.InetAddress.getAllByName0(InetAddress.java:1277)\n\tat java.net.InetAddress.getAllByName(InetAddress.java:1193)\n\tat java.net.InetAddress.getAllByName(InetAddress.java:1127)\n\tat org.apache.http.impl.conn.SystemDefaultDnsResolver.resolve(SystemDefaultDnsResolver.java:45)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager$InternalAddressResolver.resolveRemoteAddress(PoolingNHttpClientConnectionManager.java:664)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager$InternalAddressResolver.resolveRemoteAddress(PoolingNHttpClientConnectionManager.java:635)\n\tat org.apache.http.nio.pool.AbstractNIOConnPool.processPendingRequest(AbstractNIOConnPool.java:474)\n\tat org.apache.http.nio.pool.AbstractNIOConnPool.lease(AbstractNIOConnPool.java:280)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.requestConnection(PoolingNHttpClientConnectionManager.java:295)\n\tat org.apache.http.impl.nio.client.AbstractClientExchangeHandler.requestConnection(AbstractClientExchangeHandler.java:377)\n\tat org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.start(DefaultClientExchangeHandlerImpl.java:129)\n\tat org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:141)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:75)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:108)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:92)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:92)\n\t... 20 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: java.net.UnknownHostException: **WRONGlocalhost**: Try again\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:93)\n\t... 20 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:97)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher.publishFile(DataRouterPublisher.java:102)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:118)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:457)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.resubscribe(FluxRetryWhen.java:183)\n\tat reactor.core.publisher.FluxRetryWhen$RetryWhenOtherSubscriber.onNext(FluxRetryWhen.java:229)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:501)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:943)\n\tat reactor.core.publisher.MonoDelay$MonoDelayRunnable.run(MonoDelay.java:117)\n\tat reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:50)\n\tat reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:27)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |parallel-204     |
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.UnknownHostException: *WRONGlocalhost*\n\tat ... java.net.UnknownHostException: *WRONGlocalhost*\n\tat ... Unable to create web client.\n\tat ...
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.UnknownHostException: *WRONGlocalhost*: Try again\n\tat ... java.net.UnknownHostException: *WRONGlocalhost*: Try again\n\tat ... Unable to create web client.\n\tat ...
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:33:57.340Z     |ERROR     |File publishing failed: FilePublishInformation{productName=RnNode, vendorName=Ericsson, lastEpochMicrosec=8745745764578, sourceName=PNF0, startEpochMicrosec=8745745764578, timeZoneOffset=UTC+05.30, name=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, location=ftps://onap:pano@localhost:21/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, internalLocation=/tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10, context={RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz}}     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |parallel-206     |
+
+-Wrong producer dmaapPortNumber:
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.tasks.PublishedChecker     |2019-04-24T15:38:24.806Z     |WARN     |Unable to check if file has been published, file: A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |java.net.ConnectException: Connection refused\n\tat sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\n\tat sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)\n\tat org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:171)\n\tat org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:145)\n\tat org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:348)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\n\t... 1 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: java.net.ConnectException: Connection refused\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:120)\n\t... 23 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:124)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.PublishedChecker.isFilePublished(PublishedChecker.java:82)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.shouldBePublished(ScheduledTasks.java:194)\n\tat reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:93)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:449)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:384)\n\tat reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:924)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)\n\tat reactor.core.publisher.Flux.subscribe(Flux.java:7743)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:398)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:484)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |FileCollectorWorker-2     |
+    org.onap.dcaegen2.collectors.datafile.ftp.FtpsClient     |2019-04-24T15:38:24.972Z     |WARN     |Local file /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz already created     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
+    org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher     |2019-04-24T15:38:25.146Z     |WARN     |Unable to send file to DataRouter. Data: /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |java.net.ConnectException: Connection refused\n\tat sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)\n\tat sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)\n\tat org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:171)\n\tat org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:145)\n\tat org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:348)\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64)\n\t... 1 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: java.net.ConnectException: Connection refused\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:93)\n\t... 61 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:97)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher.publishFile(DataRouterPublisher.java:102)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:118)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:389)\n\tat reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2070)\n\tat reactor.core.publisher.MonoProcessor.onSubscribe(MonoProcessor.java:399)\n\tat reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.MonoProcessor.add(MonoProcessor.java:531)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:444)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:85)\n\tat reactor.core.publisher.MonoRetryWhen.subscribe(MonoRetryWhen.java:50)\n\tat reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:501)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:943)\n\tat reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:73)\n\tat reactor.core.publisher.SerializedSubscriber.onNext(SerializedSubscriber.java:89)\n\tat reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onNext(FluxRetryWhen.java:145)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:389)\n\tat reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2070)\n\tat reactor.core.publisher.MonoProcessor.onSubscribe(MonoProcessor.java:399)\n\tat reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.MonoProcessor.add(MonoProcessor.java:531)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:444)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:85)\n\tat reactor.core.publisher.MonoRetryWhen.subscribe(MonoRetryWhen.java:50)\n\tat reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:449)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:384)\n\tat reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:924)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)\n\tat reactor.core.publisher.Flux.subscribe(Flux.java:7743)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:398)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:484)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |FileCollectorWorker-2     |
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.ConnectException: Connection refused\n\tat ... Connection refused\n\tat ... Unable to create web client.\n\tat ...
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.ConnectException: Connection refused\n\tat ... Connection refused\n\tat ... Unable to create web client.\n\tat ...
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.ConnectException: Connection refused\n\tat ... Connection refused\n\tat ... Unable to create web client.\n\tat ...
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.ConnectException: Connection refused\n\tat ... Connection refused\n\tat ... Unable to create web client.\n\tat ...
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |java.net.ConnectException: Connection refused\n\tat ... Connection refused\n\tat ... Unable to create web client.\n\tat ...
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:39:38.121Z     |ERROR     |File publishing failed: FilePublishInformation{productName=RnNode, vendorName=Ericsson, lastEpochMicrosec=8745745764578, sourceName=PNF0, startEpochMicrosec=8745745764578, timeZoneOffset=UTC+05.30, name=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, location=ftps://onap:pano@localhost:21/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, internalLocation=/tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10, context={RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz}}     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |parallel-206     |
+
+-Producer dmaapTopicName:
 Not configurable.
 
-Wrong producer dmaapProtocol:
-org.onap.dcaegen2.collectors.datafile.tasks.PublishedChecker     |2019-04-24T15:47:45.906Z     |WARN     |Unable to check if file has been published, file: A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |org.apache.http.conn.UnsupportedSchemeException: **WRONGhttps** protocol is not supported\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.requestConnection(PoolingNHttpClientConnectionManager.java:291)\n\tat org.apache.http.impl.nio.client.AbstractClientExchangeHandler.requestConnection(AbstractClientExchangeHandler.java:377)\n\tat org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.start(DefaultClientExchangeHandlerImpl.java:129)\n\tat org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:141)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:75)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:108)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:92)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:119)\n\t... 23 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: org.apache.http.conn.UnsupportedSchemeException: **WRONGhttps** protocol is not supported\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:120)\n\t... 23 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:124)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.PublishedChecker.isFilePublished(PublishedChecker.java:82)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.shouldBePublished(ScheduledTasks.java:194)\n\tat reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:93)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:449)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:384)\n\tat reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:924)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)\n\tat reactor.core.publisher.Flux.subscribe(Flux.java:7743)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:398)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:484)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |FileCollectorWorker-2     |
-org.onap.dcaegen2.collectors.datafile.ftp.FtpsClient     |2019-04-24T15:47:46.102Z     |WARN     |Local file /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz already created     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
-org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher     |2019-04-24T15:47:46.227Z     |WARN     |Unable to send file to DataRouter. Data: /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |org.apache.http.conn.UnsupportedSchemeException: **WRONGhttps** protocol is not supported\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.requestConnection(PoolingNHttpClientConnectionManager.java:291)\n\tat org.apache.http.impl.nio.client.AbstractClientExchangeHandler.requestConnection(AbstractClientExchangeHandler.java:377)\n\tat org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.start(DefaultClientExchangeHandlerImpl.java:129)\n\tat org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:141)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:75)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:108)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:92)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:92)\n\t... 61 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: org.apache.http.conn.UnsupportedSchemeException: **WRONGhttps** protocol is not supported\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:93)\n\t... 61 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:97)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher.publishFile(DataRouterPublisher.java:102)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:118)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:389)\n\tat reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2070)\n\tat reactor.core.publisher.MonoProcessor.onSubscribe(MonoProcessor.java:399)\n\tat reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.MonoProcessor.add(MonoProcessor.java:531)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:444)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:85)\n\tat reactor.core.publisher.MonoRetryWhen.subscribe(MonoRetryWhen.java:50)\n\tat reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:501)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:943)\n\tat reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:73)\n\tat reactor.core.publisher.SerializedSubscriber.onNext(SerializedSubscriber.java:89)\n\tat reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onNext(FluxRetryWhen.java:145)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:389)\n\tat reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2070)\n\tat reactor.core.publisher.MonoProcessor.onSubscribe(MonoProcessor.java:399)\n\tat reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.MonoProcessor.add(MonoProcessor.java:531)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:444)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:85)\n\tat reactor.core.publisher.MonoRetryWhen.subscribe(MonoRetryWhen.java:50)\n\tat reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:449)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:384)\n\tat reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:924)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)\n\tat reactor.core.publisher.Flux.subscribe(Flux.java:7743)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:398)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:484)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |FileCollectorWorker-2     |
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |org.apache.http.conn.UnsupportedSchemeException: *WRONGhttps* protocol is not supported\n\tat ... *WRONGhttps* protocol is not supported\n\tat ... Unable to create web client.\n\tat ...
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |org.apache.http.conn.UnsupportedSchemeException: *WRONGhttps* protocol is not supported\n\tat ... *WRONGhttps* protocol is not supported\n\tat ... Unable to create web client.\n\tat ...
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |org.apache.http.conn.UnsupportedSchemeException: *WRONGhttps* protocol is not supported\n\tat ... *WRONGhttps* protocol is not supported\n\tat ... Unable to create web client.\n\tat ...
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |org.apache.http.conn.UnsupportedSchemeException: *WRONGhttps* protocol is not supported\n\tat ... *WRONGhttps* protocol is not supported\n\tat ... Unable to create web client.\n\tat ...
-\...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |org.apache.http.conn.UnsupportedSchemeException: *WRONGhttps* protocol is not supported\n\tat ... *WRONGhttps* protocol is not supported\n\tat ... Unable to create web client.\n\tat ...
-org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:48:42.406Z     |ERROR     |File publishing failed: FilePublishInformation{productName=RnNode, vendorName=Ericsson, lastEpochMicrosec=8745745764578, sourceName=PNF0, startEpochMicrosec=8745745764578, timeZoneOffset=UTC+05.30, name=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, location=ftps://onap:pano@localhost:21/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, internalLocation=/tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10, context={RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz}}     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |parallel-206     |
+-Wrong producer dmaapProtocol:
+
+.. code-block:: json
+
+    org.onap.dcaegen2.collectors.datafile.tasks.PublishedChecker     |2019-04-24T15:47:45.906Z     |WARN     |Unable to check if file has been published, file: A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |org.apache.http.conn.UnsupportedSchemeException: **WRONGhttps** protocol is not supported\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.requestConnection(PoolingNHttpClientConnectionManager.java:291)\n\tat org.apache.http.impl.nio.client.AbstractClientExchangeHandler.requestConnection(AbstractClientExchangeHandler.java:377)\n\tat org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.start(DefaultClientExchangeHandlerImpl.java:129)\n\tat org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:141)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:75)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:108)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:92)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:119)\n\t... 23 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: org.apache.http.conn.UnsupportedSchemeException: **WRONGhttps** protocol is not supported\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:120)\n\t... 23 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithCustomTimeout(DmaapProducerHttpClient.java:124)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.PublishedChecker.isFilePublished(PublishedChecker.java:82)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks.shouldBePublished(ScheduledTasks.java:194)\n\tat reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:93)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:449)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:384)\n\tat reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:924)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)\n\tat reactor.core.publisher.Flux.subscribe(Flux.java:7743)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:398)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:484)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |FileCollectorWorker-2     |
+    org.onap.dcaegen2.collectors.datafile.ftp.FtpsClient     |2019-04-24T15:47:46.102Z     |WARN     |Local file /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz already created     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |FileCollectorWorker-2     |
+    org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher     |2019-04-24T15:47:46.227Z     |WARN     |Unable to send file to DataRouter. Data: /tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |org.apache.http.conn.UnsupportedSchemeException: **WRONGhttps** protocol is not supported\n\tat org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.requestConnection(PoolingNHttpClientConnectionManager.java:291)\n\tat org.apache.http.impl.nio.client.AbstractClientExchangeHandler.requestConnection(AbstractClientExchangeHandler.java:377)\n\tat org.apache.http.impl.nio.client.DefaultClientExchangeHandlerImpl.start(DefaultClientExchangeHandlerImpl.java:129)\n\tat org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:141)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:75)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:108)\n\tat org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:92)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:92)\n\t... 61 common frames omitted\nWrapped by: java.util.concurrent.ExecutionException: org.apache.http.conn.UnsupportedSchemeException: **WRONGhttps** protocol is not supported\n\tat org.apache.http.concurrent.BasicFuture.getResult(BasicFuture.java:71)\n\tat org.apache.http.concurrent.BasicFuture.get(BasicFuture.java:84)\n\tat org.apache.http.impl.nio.client.FutureWrapper.get(FutureWrapper.java:70)\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:93)\n\t... 61 common frames omitted\nWrapped by: org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException: Unable to create web client.\n\tat org.onap.dcaegen2.collectors.datafile.service.producer.DmaapProducerHttpClient.getDmaapProducerResponseWithRedirect(DmaapProducerHttpClient.java:97)\n\tat org.onap.dcaegen2.collectors.datafile.tasks.DataRouterPublisher.publishFile(DataRouterPublisher.java:102)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:118)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:389)\n\tat reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2070)\n\tat reactor.core.publisher.MonoProcessor.onSubscribe(MonoProcessor.java:399)\n\tat reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.MonoProcessor.add(MonoProcessor.java:531)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:444)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:85)\n\tat reactor.core.publisher.MonoRetryWhen.subscribe(MonoRetryWhen.java:50)\n\tat reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:501)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:943)\n\tat reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:73)\n\tat reactor.core.publisher.SerializedSubscriber.onNext(SerializedSubscriber.java:89)\n\tat reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onNext(FluxRetryWhen.java:145)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1505)\n\tat reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:389)\n\tat reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2070)\n\tat reactor.core.publisher.MonoProcessor.onSubscribe(MonoProcessor.java:399)\n\tat reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.MonoProcessor.add(MonoProcessor.java:531)\n\tat reactor.core.publisher.MonoProcessor.subscribe(MonoProcessor.java:444)\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:85)\n\tat reactor.core.publisher.MonoRetryWhen.subscribe(MonoRetryWhen.java:50)\n\tat reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:3695)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:449)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:384)\n\tat reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:664)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:924)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)\n\tat reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)\n\tat reactor.core.publisher.Flux.subscribe(Flux.java:7743)\n\tat reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:389)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:398)\n\tat reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:484)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)\n\tat reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)\n\tat java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n     |     |FileCollectorWorker-2     |
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |org.apache.http.conn.UnsupportedSchemeException: *WRONGhttps* protocol is not supported\n\tat ... *WRONGhttps* protocol is not supported\n\tat ... Unable to create web client.\n\tat ...
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |org.apache.http.conn.UnsupportedSchemeException: *WRONGhttps* protocol is not supported\n\tat ... *WRONGhttps* protocol is not supported\n\tat ... Unable to create web client.\n\tat ...
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |org.apache.http.conn.UnsupportedSchemeException: *WRONGhttps* protocol is not supported\n\tat ... *WRONGhttps* protocol is not supported\n\tat ... Unable to create web client.\n\tat ...
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |org.apache.http.conn.UnsupportedSchemeException: *WRONGhttps* protocol is not supported\n\tat ... *WRONGhttps* protocol is not supported\n\tat ... Unable to create web client.\n\tat ...
+    \...tasks.DataRouterPublisher     ...     |WARN     |Unable to send file to DataRouter. Data: ...     |org.apache.http.conn.UnsupportedSchemeException: *WRONGhttps* protocol is not supported\n\tat ... *WRONGhttps* protocol is not supported\n\tat ... Unable to create web client.\n\tat ...
+    org.onap.dcaegen2.collectors.datafile.tasks.ScheduledTasks     |2019-04-24T15:48:42.406Z     |ERROR     |File publishing failed: FilePublishInformation{productName=RnNode, vendorName=Ericsson, lastEpochMicrosec=8745745764578, sourceName=PNF0, startEpochMicrosec=8745745764578, timeZoneOffset=UTC+05.30, name=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, location=ftps://onap:pano@localhost:21/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, internalLocation=/tmp/onap_datafile/A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10, context={RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz}}     |RequestID=A20000626.2315+0200-2330+0200_PNF0-0-1MB.tar.gz     |     |     |parallel-206     |
 
-..Wrong producer dmaapUserName:
-..No issue with the simulator, to be checked in cloud40.
+.. Wrong producer dmaapUserName:
+.. No issue with the simulator, to be checked in cloud40.
 
-..Wrong producer dmaapUserPassword:
-..No issue with the simulator, to be checked in cloud40.
+.. Wrong producer dmaapUserPassword:
+.. No issue with the simulator, to be checked in cloud40.
 
-Producer dmaapContentType:
+-Producer dmaapContentType:
 Not configurable.
 
-Security parameters:
-Not in use.
-\ No newline at end of file
+-Security parameters:
+Not in use.
author	maximesson <maxime.bonneau@est.tech>	2019-06-20 10:42:48 +0200
committer	maximesson <maxime.bonneau@est.tech>	2019-06-20 10:43:01 +0200
commit	7ee84355e06aaefbe4a91af24ee27ca4f36d2f9b (patch)
tree	b743e17e557ddbda29f309ef9db57f1487e2a211
parent	c9a8aa4dc4e7641a4e5ab0f2a81cd8d15de3b41a (diff)