2018-10-11 09:47:36.610  INFO 2387 --- [main] o.o.d.collectors.datafile.MainApp        : Starting MainApp on Chengkais-MacBook-Pro.local with PID 2387 (/Users/chengkaiyan/datafile/datafile-app-server/target/datafile-app-server.jar started by chengkaiyan in /Users/chengkaiyan/datafile/datafile-app-server)
2018-10-11 09:47:36.613 DEBUG 2387 --- [main] o.o.d.collectors.datafile.MainApp        : Running with Spring Boot v2.0.4.RELEASE, Spring v5.0.5.RELEASE
2018-10-11 09:47:36.613  INFO 2387 --- [main] o.o.d.collectors.datafile.MainApp        : The following profiles are active: prod
2018-10-11 09:47:39.671 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.datafile.tasks.ScheduledTasks    : Execution of tasks was registered
2018-10-11 09:47:39.672  INFO 2387 --- [parallel-1] o.o.d.c.d.c.EnvironmentProcessor         : Loading configuration from system environment variables
2018-10-11 09:47:39.679  WARN 2387 --- [parallel-1] o.o.d.c.d.c.CloudConfiguration           : Error in case of processing system environment, more details below: 

org.onap.dcaegen2.collectors.datafile.exceptions.EnvironmentLoaderException: $CONSUL_HOST environment has not been defined
	at org.onap.dcaegen2.collectors.datafile.configuration.EnvironmentProcessor.lambda$getConsulHost$0(EnvironmentProcessor.java:57)
	at java.util.Optional.orElseThrow(Optional.java:290)
	at org.onap.dcaegen2.collectors.datafile.configuration.EnvironmentProcessor.getConsulHost(EnvironmentProcessor.java:57)
	at org.onap.dcaegen2.collectors.datafile.configuration.EnvironmentProcessor.evaluate(EnvironmentProcessor.java:45)
	at org.onap.dcaegen2.collectors.datafile.configuration.CloudConfiguration.lambda$runTask$0(CloudConfiguration.java:64)
	at reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:47)
	at reactor.core.publisher.Flux.subscribe(Flux.java:6877)
	at reactor.core.publisher.FluxSubscribeOn$SubscribeOnSubscriber.run(FluxSubscribeOn.java:194)
	at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)
	at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

2018-10-11 09:47:39.729 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.tasks.DmaapConsumerTaskImpl    : execute called with arg 
2018-10-11 09:47:39.770 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : Request: GET http://localhost:2222/events/unauthenticated.VES_NOTIFICATION_OUTPUT/OpenDcae-c12/C12
2018-10-11 09:47:39.772  INFO 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : Content-Type=application/json
2018-10-11 09:47:39.772 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : HTTP request headers: {Content-Type=[application/json]}
2018-10-11 09:47:39.778 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.tasks.DmaapConsumerTaskImpl    : consume called with arg MonoFlatMap
2018-10-11 09:47:40.076 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapReactiveWebClient       : Response Status 200
2018-10-11 09:47:40.135 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapConsumerJsonParser      : original message from message router: 
["{\"event\":{\"commonEventHeader\":{\"startEpochMicrosec\":0000000000000,\"eventId\":\"FileReady_1797490e-10ae-4d48-9ea7-3d7d790b25e1\",\"timeZoneOffset\":\"UTC+05.30\",\"internalHeaderFields\":{\"collectorTimeStamp\":\"Wed, 09 19 2018 11:39:30 UTC\"},\"priority\":\"Normal\",\"version\":\"4.0.1\",\"reportingEntityName\":\"otenb5309\",\"sequence\":0,\"domain\":\"notification\",\"lastEpochMicrosec\":8745745764578,\"eventName\":\"Noti_RnNode-Ericsson_FileReady\",\"vesEventListenerVersion\":\"7.0.1\",\"sourceName\":\"oteNB5309\"},\"notificationFields\":{\"notificationFieldsVersion\":\"2.0\",\"changeType\":\"FileReady\",\"changeIdentifier\":\"PM_MEAS_FILES\",\"arrayOfNamedHashMap\":[{\"name\":\"fileFromFtps.tar.gz\",\"hashMap\":{\"location\":\"ftpes://myuser:mypass@localhost:21/fileFromFtps.tar.gz\",\"fileFormatType\":\"org.3GPP.32.435#measCollec\",\"fileFormatVersion\":\"V10\",\"compression\":\"gzip\"}},
{\"name\":\"fileFromSftp.tar.gz\",\"hashMap\":{\"location\":\"sftp://foo:pass@localhost:22/fileFromSftp.tar.gz\",\"fileFormatType\":\"org.3GPP.32.435#measCollec\",\"fileFormatVersion\":\"V10\",\"compression\":\"gzip\"}}]}}}"]

2018-10-11 09:47:40.137 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getJsonObjectFromAnArray!
2018-10-11 09:47:40.138 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getFileDataFromJson!
2018-10-11 09:47:40.143 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getFileDataFromJson!
2018-10-11 09:47:40.144 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Entering execute with FileData{changeIdentifier=PM_MEAS_FILES, changeType=FileReady, name=fileFromFtps.tar.gz, location=ftpes://myuser:mypass@localhost:21/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:40.149 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : starting to collectFile
2018-10-11 09:47:40.150 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : collectFile called with fileServerData: FileServerData{serverAddress=localhost, userId=myuser, password=mypass, port=21}, remoteFile: /fileFromFtps.tar.gz, localFile: target/fileFromFtps.tar.gz
2018-10-11 09:47:40.150 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile called
2018-10-11 09:47:40.531  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : complete setUpKeyManager
2018-10-11 09:47:40.537  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : complete setUpTrustedCA
2018-10-11 09:47:40.650  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : after ftp connect
2018-10-11 09:47:40.669 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : setUpConnection return value: true
2018-10-11 09:47:40.670 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : starting to getFile
2018-10-11 09:47:40.765 DEBUG 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : File target/fileFromFtps.tar.gz Download Successfull from xNF
2018-10-11 09:47:40.765 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : starting to closeDownConnection
2018-10-11 09:47:40.769 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : collectFile left with result: Download successful: true Error data: , errorData: 
2018-10-11 09:47:40.771 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Exiting execute with ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:40.771 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.DmaapPublisherTaskImpl   : Method called with arg ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:40.773 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : Entering getDmaapProducerResponse with ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:40.784 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : base64Creds...: ZHJhZG1pbjpkcmFkbWlu
2018-10-11 09:47:40.790 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : Starting to publish to DR
2018-10-11 09:47:41.019 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ===========================request begin================================================
2018-10-11 09:47:41.019 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : URI         : https://localhost:3907/publish/1/fileFromFtps.tar.gz
2018-10-11 09:47:41.019 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Method      : PUT
2018-10-11 09:47:41.019 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Headers     : {Accept=[text/plain, application/json, application/*+json, */*], Content-Type=[application/octet-stream], X-ATT-DR-META=[{"compression":"gzip","fileFormatType":"org.3GPP.32.435#measCollec","fileFormatVersion":"V10"}], Authorization=[Basic ZHJhZG1pbjpkcmFkbWlu], Content-Length=[793]}
2018-10-11 09:47:41.020 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Request body: ?H?[???ON-*?M+)(???.f?>000031Q??f?`???#ccCcc##cS3CSS???$
?????????Y???UPYZs ^Q??C???3010?&&+?+D(@
H?????8?A????e?tL
bv4%?q???\??????"???T`dX?X??%?G<?u?
???
???h??????[H?f??
I?????5B???(9??i?A?&N??	A
?Yw/6?e??j?h???????`??k?m?????&??j(d ?p?p??;{{???????x
?Ab\<,>n!
??@s?\n6gOW?C
>?3{j28?U??Vs2???&?d??%?
%R?K?JR?3??y
-,???????2
?D?:?6?GQFV??^`?v2562??:???^??Z?G]?????z?go??FqR?K?ym?,??~?????s,??9????>|:s?s??&	??}?M?[6?`???SG?5sg?8?S}3???0?&Af??+???<6O???J?r???L??h?tW?;??L??9?y&5?1|??a}8?)3?yi~Ym???_i?|??7.u?xg?cu??d?E?m?o??{??
W?
??????z?????bA?|[??????j??E????K?W????v???d's???6?<?O?2??(?8?????}3???8_??Q0
F?(?`??Q0
F?(?`??Q0
F?(?`??Q0
F?(???%(
2018-10-11 09:47:41.020 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ==========================request end================================================
2018-10-11 09:47:41.112 DEBUG 2387 --- [reactor-http-nio-4] o.o.d.c.d.web.PublishRedirectStrategy    : Redirect requested to location 'http://127.0.0.1:3908/publish/1/fileFromFtps.tar.gz'
2018-10-11 09:47:41.114 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.web.PublishRedirectStrategy    : getRedirect...: PUT https://localhost:3907/publish/1/fileFromFtps.tar.gz HTTP/1.1
2018-10-11 09:47:41.120 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ============================response begin==========================================
2018-10-11 09:47:41.120 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Status code  : 200
2018-10-11 09:47:41.121 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Status text  : OK
2018-10-11 09:47:41.121 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Headers      : {X-Powered-By=[Express], Content-Type=[text/html; charset=utf-8], Content-Length=[2], ETag=[W/"2-eoX0dku9ba8cNUXvu/DyeabcC+s"], Date=[Thu, 11 Oct 2018 07:47:41 GMT], Connection=[keep-alive]}
2018-10-11 09:47:41.121 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : =======================response end=================================================
2018-10-11 09:47:41.123  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile consumed tasks. HTTP Response code 200
2018-10-11 09:47:41.123 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Entering execute with FileData{changeIdentifier=PM_MEAS_FILES, changeType=FileReady, name=fileFromSftp.tar.gz, location=sftp://foo:pass@localhost:22/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:41.123 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : starting to collectFile
2018-10-11 09:47:41.123 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : collectFile called with fileServerData: FileServerData{serverAddress=localhost, userId=foo, password=pass, port=22}, remoteFile: /fileFromSftp.tar.gz, localFile: target/fileFromSftp.tar.gz
2018-10-11 09:47:41.124 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile called
2018-10-11 09:47:41.646  INFO 2387 --- [main] o.o.d.collectors.datafile.MainApp        : Started MainApp in 5.975 seconds (JVM running for 6.63)
2018-10-11 09:47:41.847 DEBUG 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : File fileFromSftp.tar.gz Download Successfull from xNF
2018-10-11 09:47:41.850 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile left with result: Download successful: true Error data: 
2018-10-11 09:47:41.850 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Exiting execute with ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:41.850 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.DmaapPublisherTaskImpl   : Method called with arg ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:41.850 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : Entering getDmaapProducerResponse with ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:41.851 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : base64Creds...: ZHJhZG1pbjpkcmFkbWlu
2018-10-11 09:47:41.851 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : Starting to publish to DR
2018-10-11 09:47:41.856 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ===========================request begin================================================
2018-10-11 09:47:41.856 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : URI         : https://localhost:3907/publish/1/fileFromSftp.tar.gz
2018-10-11 09:47:41.856 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Method      : PUT
2018-10-11 09:47:41.856 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Headers     : {Accept=[text/plain, application/json, application/*+json, */*], Content-Type=[application/octet-stream], X-ATT-DR-META=[{"compression":"gzip","fileFormatType":"org.3GPP.32.435#measCollec","fileFormatVersion":"V10"}], Authorization=[Basic ZHJhZG1pbjpkcmFkbWlu], Content-Length=[10240]}
2018-10-11 09:47:41.856 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Request body: fileFromSftp.txt0000644000000000000000000000003413336534767012733 0ustar  rootrootdummy text from ftps server

2018-10-11 09:47:41.857 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ==========================request end================================================
2018-10-11 09:47:41.870 DEBUG 2387 --- [reactor-http-nio-4] o.o.d.c.d.web.PublishRedirectStrategy    : Redirect requested to location 'http://127.0.0.1:3908/publish/1/fileFromSftp.tar.gz'
2018-10-11 09:47:41.871 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.web.PublishRedirectStrategy    : getRedirect...: PUT https://localhost:3907/publish/1/fileFromSftp.tar.gz HTTP/1.1
2018-10-11 09:47:41.873 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ============================response begin==========================================
2018-10-11 09:47:41.874 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Status code  : 200
2018-10-11 09:47:41.874 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Status text  : OK
2018-10-11 09:47:41.874 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Headers      : {X-Powered-By=[Express], Content-Type=[text/html; charset=utf-8], Content-Length=[2], ETag=[W/"2-eoX0dku9ba8cNUXvu/DyeabcC+s"], Date=[Thu, 11 Oct 2018 07:47:41 GMT], Connection=[keep-alive]}
2018-10-11 09:47:41.874 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : =======================response end=================================================
2018-10-11 09:47:41.874  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile consumed tasks. HTTP Response code 200
2018-10-11 09:47:41.874  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile tasks have been completed
2018-10-11 09:47:49.921 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.datafile.tasks.ScheduledTasks    : Execution of tasks was registered
2018-10-11 09:47:49.938 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.tasks.DmaapConsumerTaskImpl    : execute called with arg 
2018-10-11 09:47:49.939 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : Request: GET http://localhost:2222/events/unauthenticated.VES_NOTIFICATION_OUTPUT/OpenDcae-c12/C12
2018-10-11 09:47:49.939  INFO 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : Content-Type=application/json
2018-10-11 09:47:49.939 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : HTTP request headers: {Content-Type=[application/json]}
2018-10-11 09:47:49.939 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.tasks.DmaapConsumerTaskImpl    : consume called with arg MonoFlatMap
2018-10-11 09:47:49.945 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapReactiveWebClient       : Response Status 200
2018-10-11 09:47:49.947 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapConsumerJsonParser      : original message from message router: 
["{\"event\":{\"commonEventHeader\":{\"startEpochMicrosec\":0000000000000,\"eventId\":\"FileReady_1797490e-10ae-4d48-9ea7-3d7d790b25e1\",\"timeZoneOffset\":\"UTC+05.30\",\"internalHeaderFields\":{\"collectorTimeStamp\":\"Wed, 09 19 2018 11:39:30 UTC\"},\"priority\":\"Normal\",\"version\":\"4.0.1\",\"reportingEntityName\":\"otenb5309\",\"sequence\":0,\"domain\":\"notification\",\"lastEpochMicrosec\":8745745764578,\"eventName\":\"Noti_RnNode-Ericsson_FileReady\",\"vesEventListenerVersion\":\"7.0.1\",\"sourceName\":\"oteNB5309\"},\"notificationFields\":{\"notificationFieldsVersion\":\"2.0\",\"changeType\":\"FileReady\",\"changeIdentifier\":\"PM_MEAS_FILES\",\"arrayOfNamedHashMap\":[{\"name\":\"fileFromFtps.tar.gz\",\"hashMap\":{\"location\":\"ftpes://myuser:mypass@localhost:21/fileFromFtps.tar.gz\",\"fileFormatType\":\"org.3GPP.32.435#measCollec\",\"fileFormatVersion\":\"V10\",\"compression\":\"gzip\"}},
{\"name\":\"fileFromSftp.tar.gz\",\"hashMap\":{\"location\":\"sftp://foo:pass@localhost:22/fileFromSftp.tar.gz\",\"fileFormatType\":\"org.3GPP.32.435#measCollec\",\"fileFormatVersion\":\"V10\",\"compression\":\"gzip\"}}]}}}"]

2018-10-11 09:47:49.947 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getJsonObjectFromAnArray!
2018-10-11 09:47:49.947 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getFileDataFromJson!
2018-10-11 09:47:49.948 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getFileDataFromJson!
2018-10-11 09:47:49.948 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Entering execute with FileData{changeIdentifier=PM_MEAS_FILES, changeType=FileReady, name=fileFromFtps.tar.gz, location=ftpes://myuser:mypass@localhost:21/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:49.948 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : starting to collectFile
2018-10-11 09:47:49.948 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : collectFile called with fileServerData: FileServerData{serverAddress=localhost, userId=myuser, password=mypass, port=21}, remoteFile: /fileFromFtps.tar.gz, localFile: target/fileFromFtps.tar.gz
2018-10-11 09:47:49.948 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile called
2018-10-11 09:47:50.045  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : complete setUpKeyManager
2018-10-11 09:47:50.045  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : complete setUpTrustedCA
2018-10-11 09:47:50.069  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : after ftp connect
2018-10-11 09:47:50.085 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : setUpConnection return value: true
2018-10-11 09:47:50.085 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : starting to getFile
2018-10-11 09:47:50.185 DEBUG 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : File target/fileFromFtps.tar.gz Download Successfull from xNF
2018-10-11 09:47:50.185 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : starting to closeDownConnection
2018-10-11 09:47:50.187 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : collectFile left with result: Download successful: true Error data: , errorData: 
2018-10-11 09:47:50.187 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Exiting execute with ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:50.187 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.DmaapPublisherTaskImpl   : Method called with arg ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:50.187 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : Entering getDmaapProducerResponse with ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:50.187 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : base64Creds...: ZHJhZG1pbjpkcmFkbWlu
2018-10-11 09:47:50.188 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : Starting to publish to DR
2018-10-11 09:47:50.195 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ===========================request begin================================================
2018-10-11 09:47:50.196 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : URI         : https://localhost:3907/publish/1/fileFromFtps.tar.gz
2018-10-11 09:47:50.196 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Method      : PUT
2018-10-11 09:47:50.196 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Headers     : {Accept=[text/plain, application/json, application/*+json, */*], Content-Type=[application/octet-stream], X-ATT-DR-META=[{"compression":"gzip","fileFormatType":"org.3GPP.32.435#measCollec","fileFormatVersion":"V10"}], Authorization=[Basic ZHJhZG1pbjpkcmFkbWlu], Content-Length=[793]}
2018-10-11 09:47:50.196 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Request body: ?H?[???ON-*?M+)(???.f?>000031Q??f?`???#ccCcc##cS3CSS???$
?????????Y???UPYZs ^Q??C???3010?&&+?+D(@
H?????8?A????e?tL
bv4%?q???\??????"???T`dX?X??%?G<?u?
???
???h??????[H?f??
I?????5B???(9??i?A?&N??	A
?Yw/6?e??j?h???????`??k?m?????&??j(d ?p?p??;{{???????x
?Ab\<,>n!
??@s?\n6gOW?C
>?3{j28?U??Vs2???&?d??%?
%R?K?JR?3??y
-,???????2
?D?:?6?GQFV??^`?v2562??:???^??Z?G]?????z?go??FqR?K?ym?,??~?????s,??9????>|:s?s??&	??}?M?[6?`???SG?5sg?8?S}3???0?&Af??+???<6O???J?r???L??h?tW?;??L??9?y&5?1|??a}8?)3?yi~Ym???_i?|??7.u?xg?cu??d?E?m?o??{??
W?
??????z?????bA?|[??????j??E????K?W????v???d's???6?<?O?2??(?8?????}3???8_??Q0
F?(?`??Q0
F?(?`??Q0
F?(?`??Q0
F?(???%(
2018-10-11 09:47:50.196 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ==========================request end================================================
2018-10-11 09:47:50.205 DEBUG 2387 --- [reactor-http-nio-2] o.o.d.c.d.web.PublishRedirectStrategy    : Redirect requested to location 'http://127.0.0.1:3908/publish/1/fileFromFtps.tar.gz'
2018-10-11 09:47:50.206 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.web.PublishRedirectStrategy    : getRedirect...: PUT https://localhost:3907/publish/1/fileFromFtps.tar.gz HTTP/1.1
2018-10-11 09:47:50.208 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ============================response begin==========================================
2018-10-11 09:47:50.208 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Status code  : 200
2018-10-11 09:47:50.208 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Status text  : OK
2018-10-11 09:47:50.208 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Headers      : {X-Powered-By=[Express], Content-Type=[text/html; charset=utf-8], Content-Length=[2], ETag=[W/"2-eoX0dku9ba8cNUXvu/DyeabcC+s"], Date=[Thu, 11 Oct 2018 07:47:50 GMT], Connection=[keep-alive]}
2018-10-11 09:47:50.208 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : =======================response end=================================================
2018-10-11 09:47:50.209  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile consumed tasks. HTTP Response code 200
2018-10-11 09:47:50.209 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Entering execute with FileData{changeIdentifier=PM_MEAS_FILES, changeType=FileReady, name=fileFromSftp.tar.gz, location=sftp://foo:pass@localhost:22/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:50.209 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : starting to collectFile
2018-10-11 09:47:50.209 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : collectFile called with fileServerData: FileServerData{serverAddress=localhost, userId=foo, password=pass, port=22}, remoteFile: /fileFromSftp.tar.gz, localFile: target/fileFromSftp.tar.gz
2018-10-11 09:47:50.209 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile called
2018-10-11 09:47:50.819 DEBUG 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : File fileFromSftp.tar.gz Download Successfull from xNF
2018-10-11 09:47:50.820 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile left with result: Download successful: true Error data: 
2018-10-11 09:47:50.820 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Exiting execute with ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:50.820 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.DmaapPublisherTaskImpl   : Method called with arg ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:50.820 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : Entering getDmaapProducerResponse with ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:50.821 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : base64Creds...: ZHJhZG1pbjpkcmFkbWlu
2018-10-11 09:47:50.821 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : Starting to publish to DR
2018-10-11 09:47:50.828 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ===========================request begin================================================
2018-10-11 09:47:50.828 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : URI         : https://localhost:3907/publish/1/fileFromSftp.tar.gz
2018-10-11 09:47:50.828 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Method      : PUT
2018-10-11 09:47:50.828 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Headers     : {Accept=[text/plain, application/json, application/*+json, */*], Content-Type=[application/octet-stream], X-ATT-DR-META=[{"compression":"gzip","fileFormatType":"org.3GPP.32.435#measCollec","fileFormatVersion":"V10"}], Authorization=[Basic ZHJhZG1pbjpkcmFkbWlu], Content-Length=[10240]}
2018-10-11 09:47:50.828 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Request body: fileFromSftp.txt0000644000000000000000000000003413336534767012733 0ustar  rootrootdummy text from ftps server

2018-10-11 09:47:50.829 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ==========================request end================================================
2018-10-11 09:47:50.841 DEBUG 2387 --- [reactor-http-nio-2] o.o.d.c.d.web.PublishRedirectStrategy    : Redirect requested to location 'http://127.0.0.1:3908/publish/1/fileFromSftp.tar.gz'
2018-10-11 09:47:50.841 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.web.PublishRedirectStrategy    : getRedirect...: PUT https://localhost:3907/publish/1/fileFromSftp.tar.gz HTTP/1.1
2018-10-11 09:47:50.844 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ============================response begin==========================================
2018-10-11 09:47:50.844 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Status code  : 200
2018-10-11 09:47:50.844 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Status text  : OK
2018-10-11 09:47:50.844 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Headers      : {X-Powered-By=[Express], Content-Type=[text/html; charset=utf-8], Content-Length=[2], ETag=[W/"2-eoX0dku9ba8cNUXvu/DyeabcC+s"], Date=[Thu, 11 Oct 2018 07:47:50 GMT], Connection=[keep-alive]}
2018-10-11 09:47:50.844 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : =======================response end=================================================
2018-10-11 09:47:50.844  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile consumed tasks. HTTP Response code 200
2018-10-11 09:47:50.844  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile tasks have been completed
2018-10-11 09:47:59.940 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.datafile.tasks.ScheduledTasks    : Execution of tasks was registered
2018-10-11 09:47:59.952 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.tasks.DmaapConsumerTaskImpl    : execute called with arg 
2018-10-11 09:47:59.953 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : Request: GET http://localhost:2222/events/unauthenticated.VES_NOTIFICATION_OUTPUT/OpenDcae-c12/C12
2018-10-11 09:47:59.953  INFO 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : Content-Type=application/json
2018-10-11 09:47:59.953 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : HTTP request headers: {Content-Type=[application/json]}
2018-10-11 09:47:59.953 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.tasks.DmaapConsumerTaskImpl    : consume called with arg MonoFlatMap
2018-10-11 09:47:59.957 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapReactiveWebClient       : Response Status 200
2018-10-11 09:47:59.959 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapConsumerJsonParser      : original message from message router: 
["{\"event\":{\"commonEventHeader\":{\"startEpochMicrosec\":0000000000000,\"eventId\":\"FileReady_1797490e-10ae-4d48-9ea7-3d7d790b25e1\",\"timeZoneOffset\":\"UTC+05.30\",\"internalHeaderFields\":{\"collectorTimeStamp\":\"Wed, 09 19 2018 11:39:30 UTC\"},\"priority\":\"Normal\",\"version\":\"4.0.1\",\"reportingEntityName\":\"otenb5309\",\"sequence\":0,\"domain\":\"notification\",\"lastEpochMicrosec\":8745745764578,\"eventName\":\"Noti_RnNode-Ericsson_FileReady\",\"vesEventListenerVersion\":\"7.0.1\",\"sourceName\":\"oteNB5309\"},\"notificationFields\":{\"notificationFieldsVersion\":\"2.0\",\"changeType\":\"FileReady\",\"changeIdentifier\":\"PM_MEAS_FILES\",\"arrayOfNamedHashMap\":[{\"name\":\"fileFromFtps.tar.gz\",\"hashMap\":{\"location\":\"ftpes://myuser:mypass@localhost:21/fileFromFtps.tar.gz\",\"fileFormatType\":\"org.3GPP.32.435#measCollec\",\"fileFormatVersion\":\"V10\",\"compression\":\"gzip\"}},
{\"name\":\"fileFromSftp.tar.gz\",\"hashMap\":{\"location\":\"sftp://foo:pass@localhost:22/fileFromSftp.tar.gz\",\"fileFormatType\":\"org.3GPP.32.435#measCollec\",\"fileFormatVersion\":\"V10\",\"compression\":\"gzip\"}}]}}}"]

2018-10-11 09:47:59.959 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getJsonObjectFromAnArray!
2018-10-11 09:47:59.960 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getFileDataFromJson!
2018-10-11 09:47:59.960 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getFileDataFromJson!
2018-10-11 09:47:59.960 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Entering execute with FileData{changeIdentifier=PM_MEAS_FILES, changeType=FileReady, name=fileFromFtps.tar.gz, location=ftpes://myuser:mypass@localhost:21/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:47:59.960 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : starting to collectFile
2018-10-11 09:47:59.960 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : collectFile called with fileServerData: FileServerData{serverAddress=localhost, userId=myuser, password=mypass, port=21}, remoteFile: /fileFromFtps.tar.gz, localFile: target/fileFromFtps.tar.gz
2018-10-11 09:47:59.960 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile called
2018-10-11 09:48:00.062  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : complete setUpKeyManager
2018-10-11 09:48:00.062  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : complete setUpTrustedCA
2018-10-11 09:48:00.082  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : after ftp connect
2018-10-11 09:48:00.095 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : setUpConnection return value: true
2018-10-11 09:48:00.095 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : starting to getFile
2018-10-11 09:48:00.177 DEBUG 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : File target/fileFromFtps.tar.gz Download Successfull from xNF
2018-10-11 09:48:00.177 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : starting to closeDownConnection
2018-10-11 09:48:00.179 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : collectFile left with result: Download successful: true Error data: , errorData: 
2018-10-11 09:48:00.179 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Exiting execute with ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:00.179 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.DmaapPublisherTaskImpl   : Method called with arg ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:00.179 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : Entering getDmaapProducerResponse with ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:00.180 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : base64Creds...: ZHJhZG1pbjpkcmFkbWlu
2018-10-11 09:48:00.180 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : Starting to publish to DR
2018-10-11 09:48:00.187 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ===========================request begin================================================
2018-10-11 09:48:00.187 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : URI         : https://localhost:3907/publish/1/fileFromFtps.tar.gz
2018-10-11 09:48:00.187 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Method      : PUT
2018-10-11 09:48:00.187 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Headers     : {Accept=[text/plain, application/json, application/*+json, */*], Content-Type=[application/octet-stream], X-ATT-DR-META=[{"compression":"gzip","fileFormatType":"org.3GPP.32.435#measCollec","fileFormatVersion":"V10"}], Authorization=[Basic ZHJhZG1pbjpkcmFkbWlu], Content-Length=[793]}
2018-10-11 09:48:00.187 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Request body: ?H?[???ON-*?M+)(???.f?>000031Q??f?`???#ccCcc##cS3CSS???$
?????????Y???UPYZs ^Q??C???3010?&&+?+D(@
H?????8?A????e?tL
bv4%?q???\??????"???T`dX?X??%?G<?u?
???
???h??????[H?f??
I?????5B???(9??i?A?&N??	A
?Yw/6?e??j?h???????`??k?m?????&??j(d ?p?p??;{{???????x
?Ab\<,>n!
??@s?\n6gOW?C
>?3{j28?U??Vs2???&?d??%?
%R?K?JR?3??y
-,???????2
?D?:?6?GQFV??^`?v2562??:???^??Z?G]?????z?go??FqR?K?ym?,??~?????s,??9????>|:s?s??&	??}?M?[6?`???SG?5sg?8?S}3???0?&Af??+???<6O???J?r???L??h?tW?;??L??9?y&5?1|??a}8?)3?yi~Ym???_i?|??7.u?xg?cu??d?E?m?o??{??
W?
??????z?????bA?|[??????j??E????K?W????v???d's???6?<?O?2??(?8?????}3???8_??Q0
F?(?`??Q0
F?(?`??Q0
F?(?`??Q0
F?(???%(
2018-10-11 09:48:00.187 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ==========================request end================================================
2018-10-11 09:48:00.196 DEBUG 2387 --- [reactor-http-nio-4] o.o.d.c.d.web.PublishRedirectStrategy    : Redirect requested to location 'http://127.0.0.1:3908/publish/1/fileFromFtps.tar.gz'
2018-10-11 09:48:00.197 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.web.PublishRedirectStrategy    : getRedirect...: PUT https://localhost:3907/publish/1/fileFromFtps.tar.gz HTTP/1.1
2018-10-11 09:48:00.199 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ============================response begin==========================================
2018-10-11 09:48:00.199 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Status code  : 200
2018-10-11 09:48:00.199 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Status text  : OK
2018-10-11 09:48:00.199 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Headers      : {X-Powered-By=[Express], Content-Type=[text/html; charset=utf-8], Content-Length=[2], ETag=[W/"2-eoX0dku9ba8cNUXvu/DyeabcC+s"], Date=[Thu, 11 Oct 2018 07:48:00 GMT], Connection=[keep-alive]}
2018-10-11 09:48:00.199 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : =======================response end=================================================
2018-10-11 09:48:00.199  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile consumed tasks. HTTP Response code 200
2018-10-11 09:48:00.199 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Entering execute with FileData{changeIdentifier=PM_MEAS_FILES, changeType=FileReady, name=fileFromSftp.tar.gz, location=sftp://foo:pass@localhost:22/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:00.200 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : starting to collectFile
2018-10-11 09:48:00.200 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : collectFile called with fileServerData: FileServerData{serverAddress=localhost, userId=foo, password=pass, port=22}, remoteFile: /fileFromSftp.tar.gz, localFile: target/fileFromSftp.tar.gz
2018-10-11 09:48:00.200 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile called
2018-10-11 09:48:00.828 DEBUG 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : File fileFromSftp.tar.gz Download Successfull from xNF
2018-10-11 09:48:00.828 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile left with result: Download successful: true Error data: 
2018-10-11 09:48:00.828 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Exiting execute with ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:00.829 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.DmaapPublisherTaskImpl   : Method called with arg ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:00.829 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : Entering getDmaapProducerResponse with ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:00.829 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : base64Creds...: ZHJhZG1pbjpkcmFkbWlu
2018-10-11 09:48:00.829 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : Starting to publish to DR
2018-10-11 09:48:00.833 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ===========================request begin================================================
2018-10-11 09:48:00.833 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : URI         : https://localhost:3907/publish/1/fileFromSftp.tar.gz
2018-10-11 09:48:00.834 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Method      : PUT
2018-10-11 09:48:00.834 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Headers     : {Accept=[text/plain, application/json, application/*+json, */*], Content-Type=[application/octet-stream], X-ATT-DR-META=[{"compression":"gzip","fileFormatType":"org.3GPP.32.435#measCollec","fileFormatVersion":"V10"}], Authorization=[Basic ZHJhZG1pbjpkcmFkbWlu], Content-Length=[10240]}
2018-10-11 09:48:00.834 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Request body: fileFromSftp.txt0000644000000000000000000000003413336534767012733 0ustar  rootrootdummy text from ftps server

2018-10-11 09:48:00.834 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ==========================request end================================================
2018-10-11 09:48:00.842 DEBUG 2387 --- [reactor-http-nio-4] o.o.d.c.d.web.PublishRedirectStrategy    : Redirect requested to location 'http://127.0.0.1:3908/publish/1/fileFromSftp.tar.gz'
2018-10-11 09:48:00.842 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.web.PublishRedirectStrategy    : getRedirect...: PUT https://localhost:3907/publish/1/fileFromSftp.tar.gz HTTP/1.1
2018-10-11 09:48:00.844 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ============================response begin==========================================
2018-10-11 09:48:00.844 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Status code  : 200
2018-10-11 09:48:00.844 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Status text  : OK
2018-10-11 09:48:00.844 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Headers      : {X-Powered-By=[Express], Content-Type=[text/html; charset=utf-8], Content-Length=[2], ETag=[W/"2-eoX0dku9ba8cNUXvu/DyeabcC+s"], Date=[Thu, 11 Oct 2018 07:48:00 GMT], Connection=[keep-alive]}
2018-10-11 09:48:00.844 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : =======================response end=================================================
2018-10-11 09:48:00.845  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile consumed tasks. HTTP Response code 200
2018-10-11 09:48:00.845  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile tasks have been completed
2018-10-11 09:48:09.958 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.datafile.tasks.ScheduledTasks    : Execution of tasks was registered
2018-10-11 09:48:09.966 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.tasks.DmaapConsumerTaskImpl    : execute called with arg 
2018-10-11 09:48:09.967 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : Request: GET http://localhost:2222/events/unauthenticated.VES_NOTIFICATION_OUTPUT/OpenDcae-c12/C12
2018-10-11 09:48:09.967  INFO 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : Content-Type=application/json
2018-10-11 09:48:09.967 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : HTTP request headers: {Content-Type=[application/json]}
2018-10-11 09:48:09.967 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.tasks.DmaapConsumerTaskImpl    : consume called with arg MonoFlatMap
2018-10-11 09:48:09.971 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapReactiveWebClient       : Response Status 200
2018-10-11 09:48:09.973 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapConsumerJsonParser      : original message from message router: 
["{\"event\":{\"commonEventHeader\":{\"startEpochMicrosec\":0000000000000,\"eventId\":\"FileReady_1797490e-10ae-4d48-9ea7-3d7d790b25e1\",\"timeZoneOffset\":\"UTC+05.30\",\"internalHeaderFields\":{\"collectorTimeStamp\":\"Wed, 09 19 2018 11:39:30 UTC\"},\"priority\":\"Normal\",\"version\":\"4.0.1\",\"reportingEntityName\":\"otenb5309\",\"sequence\":0,\"domain\":\"notification\",\"lastEpochMicrosec\":8745745764578,\"eventName\":\"Noti_RnNode-Ericsson_FileReady\",\"vesEventListenerVersion\":\"7.0.1\",\"sourceName\":\"oteNB5309\"},\"notificationFields\":{\"notificationFieldsVersion\":\"2.0\",\"changeType\":\"FileReady\",\"changeIdentifier\":\"PM_MEAS_FILES\",\"arrayOfNamedHashMap\":[{\"name\":\"fileFromFtps.tar.gz\",\"hashMap\":{\"location\":\"ftpes://myuser:mypass@localhost:21/fileFromFtps.tar.gz\",\"fileFormatType\":\"org.3GPP.32.435#measCollec\",\"fileFormatVersion\":\"V10\",\"compression\":\"gzip\"}},
{\"name\":\"fileFromSftp.tar.gz\",\"hashMap\":{\"location\":\"sftp://foo:pass@localhost:22/fileFromSftp.tar.gz\",\"fileFormatType\":\"org.3GPP.32.435#measCollec\",\"fileFormatVersion\":\"V10\",\"compression\":\"gzip\"}}]}}}"]

2018-10-11 09:48:09.973 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getJsonObjectFromAnArray!
2018-10-11 09:48:09.973 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getFileDataFromJson!
2018-10-11 09:48:09.973 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getFileDataFromJson!
2018-10-11 09:48:09.973 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Entering execute with FileData{changeIdentifier=PM_MEAS_FILES, changeType=FileReady, name=fileFromFtps.tar.gz, location=ftpes://myuser:mypass@localhost:21/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:09.973 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : starting to collectFile
2018-10-11 09:48:09.973 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : collectFile called with fileServerData: FileServerData{serverAddress=localhost, userId=myuser, password=mypass, port=21}, remoteFile: /fileFromFtps.tar.gz, localFile: target/fileFromFtps.tar.gz
2018-10-11 09:48:09.973 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile called
2018-10-11 09:48:10.089  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : complete setUpKeyManager
2018-10-11 09:48:10.091  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : complete setUpTrustedCA
2018-10-11 09:48:10.104  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : after ftp connect
2018-10-11 09:48:10.115 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : setUpConnection return value: true
2018-10-11 09:48:10.116 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : starting to getFile
2018-10-11 09:48:10.211 DEBUG 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : File target/fileFromFtps.tar.gz Download Successfull from xNF
2018-10-11 09:48:10.211 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : starting to closeDownConnection
2018-10-11 09:48:10.213 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : collectFile left with result: Download successful: true Error data: , errorData: 
2018-10-11 09:48:10.214 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Exiting execute with ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:10.214 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.DmaapPublisherTaskImpl   : Method called with arg ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:10.214 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : Entering getDmaapProducerResponse with ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:10.215 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : base64Creds...: ZHJhZG1pbjpkcmFkbWlu
2018-10-11 09:48:10.215 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : Starting to publish to DR
2018-10-11 09:48:10.222 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ===========================request begin================================================
2018-10-11 09:48:10.222 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : URI         : https://localhost:3907/publish/1/fileFromFtps.tar.gz
2018-10-11 09:48:10.222 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Method      : PUT
2018-10-11 09:48:10.222 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Headers     : {Accept=[text/plain, application/json, application/*+json, */*], Content-Type=[application/octet-stream], X-ATT-DR-META=[{"compression":"gzip","fileFormatType":"org.3GPP.32.435#measCollec","fileFormatVersion":"V10"}], Authorization=[Basic ZHJhZG1pbjpkcmFkbWlu], Content-Length=[793]}
2018-10-11 09:48:10.222 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Request body: ?H?[???ON-*?M+)(???.f?>000031Q??f?`???#ccCcc##cS3CSS???$
?????????Y???UPYZs ^Q??C???3010?&&+?+D(@
H?????8?A????e?tL
bv4%?q???\??????"???T`dX?X??%?G<?u?
???
???h??????[H?f??
I?????5B???(9??i?A?&N??	A
?Yw/6?e??j?h???????`??k?m?????&??j(d ?p?p??;{{???????x
?Ab\<,>n!
??@s?\n6gOW?C
>?3{j28?U??Vs2???&?d??%?
%R?K?JR?3??y
-,???????2
?D?:?6?GQFV??^`?v2562??:???^??Z?G]?????z?go??FqR?K?ym?,??~?????s,??9????>|:s?s??&	??}?M?[6?`???SG?5sg?8?S}3???0?&Af??+???<6O???J?r???L??h?tW?;??L??9?y&5?1|??a}8?)3?yi~Ym???_i?|??7.u?xg?cu??d?E?m?o??{??
W?
??????z?????bA?|[??????j??E????K?W????v???d's???6?<?O?2??(?8?????}3???8_??Q0
F?(?`??Q0
F?(?`??Q0
F?(?`??Q0
F?(???%(
2018-10-11 09:48:10.222 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ==========================request end================================================
2018-10-11 09:48:10.231 DEBUG 2387 --- [reactor-http-nio-2] o.o.d.c.d.web.PublishRedirectStrategy    : Redirect requested to location 'http://127.0.0.1:3908/publish/1/fileFromFtps.tar.gz'
2018-10-11 09:48:10.231 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.web.PublishRedirectStrategy    : getRedirect...: PUT https://localhost:3907/publish/1/fileFromFtps.tar.gz HTTP/1.1
2018-10-11 09:48:10.233 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ============================response begin==========================================
2018-10-11 09:48:10.233 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Status code  : 200
2018-10-11 09:48:10.233 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Status text  : OK
2018-10-11 09:48:10.233 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Headers      : {X-Powered-By=[Express], Content-Type=[text/html; charset=utf-8], Content-Length=[2], ETag=[W/"2-eoX0dku9ba8cNUXvu/DyeabcC+s"], Date=[Thu, 11 Oct 2018 07:48:10 GMT], Connection=[keep-alive]}
2018-10-11 09:48:10.233 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : =======================response end=================================================
2018-10-11 09:48:10.233  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile consumed tasks. HTTP Response code 200
2018-10-11 09:48:10.233 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Entering execute with FileData{changeIdentifier=PM_MEAS_FILES, changeType=FileReady, name=fileFromSftp.tar.gz, location=sftp://foo:pass@localhost:22/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:10.233 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : starting to collectFile
2018-10-11 09:48:10.234 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : collectFile called with fileServerData: FileServerData{serverAddress=localhost, userId=foo, password=pass, port=22}, remoteFile: /fileFromSftp.tar.gz, localFile: target/fileFromSftp.tar.gz
2018-10-11 09:48:10.234 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile called
2018-10-11 09:48:10.805 DEBUG 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : File fileFromSftp.tar.gz Download Successfull from xNF
2018-10-11 09:48:10.806 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile left with result: Download successful: true Error data: 
2018-10-11 09:48:10.807 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Exiting execute with ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:10.807 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.DmaapPublisherTaskImpl   : Method called with arg ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:10.807 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : Entering getDmaapProducerResponse with ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:10.807 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : base64Creds...: ZHJhZG1pbjpkcmFkbWlu
2018-10-11 09:48:10.808 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : Starting to publish to DR
2018-10-11 09:48:10.816 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ===========================request begin================================================
2018-10-11 09:48:10.816 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : URI         : https://localhost:3907/publish/1/fileFromSftp.tar.gz
2018-10-11 09:48:10.816 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Method      : PUT
2018-10-11 09:48:10.816 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Headers     : {Accept=[text/plain, application/json, application/*+json, */*], Content-Type=[application/octet-stream], X-ATT-DR-META=[{"compression":"gzip","fileFormatType":"org.3GPP.32.435#measCollec","fileFormatVersion":"V10"}], Authorization=[Basic ZHJhZG1pbjpkcmFkbWlu], Content-Length=[10240]}
2018-10-11 09:48:10.816 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Request body: fileFromSftp.txt0000644000000000000000000000003413336534767012733 0ustar  rootrootdummy text from ftps server

2018-10-11 09:48:10.816 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ==========================request end================================================
2018-10-11 09:48:10.829 DEBUG 2387 --- [reactor-http-nio-2] o.o.d.c.d.web.PublishRedirectStrategy    : Redirect requested to location 'http://127.0.0.1:3908/publish/1/fileFromSftp.tar.gz'
2018-10-11 09:48:10.829 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.web.PublishRedirectStrategy    : getRedirect...: PUT https://localhost:3907/publish/1/fileFromSftp.tar.gz HTTP/1.1
2018-10-11 09:48:10.836 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ============================response begin==========================================
2018-10-11 09:48:10.836 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Status code  : 200
2018-10-11 09:48:10.836 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Status text  : OK
2018-10-11 09:48:10.836 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Headers      : {X-Powered-By=[Express], Content-Type=[text/html; charset=utf-8], Content-Length=[2], ETag=[W/"2-eoX0dku9ba8cNUXvu/DyeabcC+s"], Date=[Thu, 11 Oct 2018 07:48:10 GMT], Connection=[keep-alive]}
2018-10-11 09:48:10.836 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : =======================response end=================================================
2018-10-11 09:48:10.836  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile consumed tasks. HTTP Response code 200
2018-10-11 09:48:10.836  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile tasks have been completed
2018-10-11 09:48:19.972 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.datafile.tasks.ScheduledTasks    : Execution of tasks was registered
2018-10-11 09:48:19.988 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.tasks.DmaapConsumerTaskImpl    : execute called with arg 
2018-10-11 09:48:19.988 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : Request: GET http://localhost:2222/events/unauthenticated.VES_NOTIFICATION_OUTPUT/OpenDcae-c12/C12
2018-10-11 09:48:19.988  INFO 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : Content-Type=application/json
2018-10-11 09:48:19.988 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : HTTP request headers: {Content-Type=[application/json]}
2018-10-11 09:48:19.988 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.tasks.DmaapConsumerTaskImpl    : consume called with arg MonoFlatMap
2018-10-11 09:48:19.991 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapReactiveWebClient       : Response Status 200
2018-10-11 09:48:19.992 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapConsumerJsonParser      : original message from message router: 
["{\"event\":{\"commonEventHeader\":{\"startEpochMicrosec\":0000000000000,\"eventId\":\"FileReady_1797490e-10ae-4d48-9ea7-3d7d790b25e1\",\"timeZoneOffset\":\"UTC+05.30\",\"internalHeaderFields\":{\"collectorTimeStamp\":\"Wed, 09 19 2018 11:39:30 UTC\"},\"priority\":\"Normal\",\"version\":\"4.0.1\",\"reportingEntityName\":\"otenb5309\",\"sequence\":0,\"domain\":\"notification\",\"lastEpochMicrosec\":8745745764578,\"eventName\":\"Noti_RnNode-Ericsson_FileReady\",\"vesEventListenerVersion\":\"7.0.1\",\"sourceName\":\"oteNB5309\"},\"notificationFields\":{\"notificationFieldsVersion\":\"2.0\",\"changeType\":\"FileReady\",\"changeIdentifier\":\"PM_MEAS_FILES\",\"arrayOfNamedHashMap\":[{\"name\":\"fileFromFtps.tar.gz\",\"hashMap\":{\"location\":\"ftpes://myuser:mypass@localhost:21/fileFromFtps.tar.gz\",\"fileFormatType\":\"org.3GPP.32.435#measCollec\",\"fileFormatVersion\":\"V10\",\"compression\":\"gzip\"}},
{\"name\":\"fileFromSftp.tar.gz\",\"hashMap\":{\"location\":\"sftp://foo:pass@localhost:22/fileFromSftp.tar.gz\",\"fileFormatType\":\"org.3GPP.32.435#measCollec\",\"fileFormatVersion\":\"V10\",\"compression\":\"gzip\"}}]}}}"]

2018-10-11 09:48:19.993 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getJsonObjectFromAnArray!
2018-10-11 09:48:19.993 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getFileDataFromJson!
2018-10-11 09:48:19.993 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getFileDataFromJson!
2018-10-11 09:48:19.993 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Entering execute with FileData{changeIdentifier=PM_MEAS_FILES, changeType=FileReady, name=fileFromFtps.tar.gz, location=ftpes://myuser:mypass@localhost:21/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:19.993 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : starting to collectFile
2018-10-11 09:48:19.993 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : collectFile called with fileServerData: FileServerData{serverAddress=localhost, userId=myuser, password=mypass, port=21}, remoteFile: /fileFromFtps.tar.gz, localFile: target/fileFromFtps.tar.gz
2018-10-11 09:48:19.993 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile called
2018-10-11 09:48:20.104  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : complete setUpKeyManager
2018-10-11 09:48:20.106  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : complete setUpTrustedCA
2018-10-11 09:48:20.122  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : after ftp connect
2018-10-11 09:48:20.134 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : setUpConnection return value: true
2018-10-11 09:48:20.134 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : starting to getFile
2018-10-11 09:48:20.215 DEBUG 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : File target/fileFromFtps.tar.gz Download Successfull from xNF
2018-10-11 09:48:20.215 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : starting to closeDownConnection
2018-10-11 09:48:20.219 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : collectFile left with result: Download successful: true Error data: , errorData: 
2018-10-11 09:48:20.220 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Exiting execute with ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:20.220 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.DmaapPublisherTaskImpl   : Method called with arg ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:20.220 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : Entering getDmaapProducerResponse with ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:20.220 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : base64Creds...: ZHJhZG1pbjpkcmFkbWlu
2018-10-11 09:48:20.221 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : Starting to publish to DR
2018-10-11 09:48:20.229 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ===========================request begin================================================
2018-10-11 09:48:20.229 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : URI         : https://localhost:3907/publish/1/fileFromFtps.tar.gz
2018-10-11 09:48:20.229 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Method      : PUT
2018-10-11 09:48:20.229 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Headers     : {Accept=[text/plain, application/json, application/*+json, */*], Content-Type=[application/octet-stream], X-ATT-DR-META=[{"compression":"gzip","fileFormatType":"org.3GPP.32.435#measCollec","fileFormatVersion":"V10"}], Authorization=[Basic ZHJhZG1pbjpkcmFkbWlu], Content-Length=[793]}
2018-10-11 09:48:20.229 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Request body: ?H?[???ON-*?M+)(???.f?>000031Q??f?`???#ccCcc##cS3CSS???$
?????????Y???UPYZs ^Q??C???3010?&&+?+D(@
H?????8?A????e?tL
bv4%?q???\??????"???T`dX?X??%?G<?u?
???
???h??????[H?f??
I?????5B???(9??i?A?&N??	A
?Yw/6?e??j?h???????`??k?m?????&??j(d ?p?p??;{{???????x
?Ab\<,>n!
??@s?\n6gOW?C
>?3{j28?U??Vs2???&?d??%?
%R?K?JR?3??y
-,???????2
?D?:?6?GQFV??^`?v2562??:???^??Z?G]?????z?go??FqR?K?ym?,??~?????s,??9????>|:s?s??&	??}?M?[6?`???SG?5sg?8?S}3???0?&Af??+???<6O???J?r???L??h?tW?;??L??9?y&5?1|??a}8?)3?yi~Ym???_i?|??7.u?xg?cu??d?E?m?o??{??
W?
??????z?????bA?|[??????j??E????K?W????v???d's???6?<?O?2??(?8?????}3???8_??Q0
F?(?`??Q0
F?(?`??Q0
F?(?`??Q0
F?(???%(
2018-10-11 09:48:20.229 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ==========================request end================================================
2018-10-11 09:48:20.239 DEBUG 2387 --- [reactor-http-nio-4] o.o.d.c.d.web.PublishRedirectStrategy    : Redirect requested to location 'http://127.0.0.1:3908/publish/1/fileFromFtps.tar.gz'
2018-10-11 09:48:20.239 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.web.PublishRedirectStrategy    : getRedirect...: PUT https://localhost:3907/publish/1/fileFromFtps.tar.gz HTTP/1.1
2018-10-11 09:48:20.243 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ============================response begin==========================================
2018-10-11 09:48:20.243 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Status code  : 200
2018-10-11 09:48:20.244 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Status text  : OK
2018-10-11 09:48:20.244 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Headers      : {X-Powered-By=[Express], Content-Type=[text/html; charset=utf-8], Content-Length=[2], ETag=[W/"2-eoX0dku9ba8cNUXvu/DyeabcC+s"], Date=[Thu, 11 Oct 2018 07:48:20 GMT], Connection=[keep-alive]}
2018-10-11 09:48:20.244 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : =======================response end=================================================
2018-10-11 09:48:20.244  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile consumed tasks. HTTP Response code 200
2018-10-11 09:48:20.244 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Entering execute with FileData{changeIdentifier=PM_MEAS_FILES, changeType=FileReady, name=fileFromSftp.tar.gz, location=sftp://foo:pass@localhost:22/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:20.244 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : starting to collectFile
2018-10-11 09:48:20.245 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : collectFile called with fileServerData: FileServerData{serverAddress=localhost, userId=foo, password=pass, port=22}, remoteFile: /fileFromSftp.tar.gz, localFile: target/fileFromSftp.tar.gz
2018-10-11 09:48:20.245 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile called
2018-10-11 09:48:20.907 DEBUG 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : File fileFromSftp.tar.gz Download Successfull from xNF
2018-10-11 09:48:20.907 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile left with result: Download successful: true Error data: 
2018-10-11 09:48:20.907 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Exiting execute with ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:20.907 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.tasks.DmaapPublisherTaskImpl   : Method called with arg ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:20.908 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : Entering getDmaapProducerResponse with ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:20.908 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : base64Creds...: ZHJhZG1pbjpkcmFkbWlu
2018-10-11 09:48:20.908 TRACE 2387 --- [reactor-http-nio-4] .c.d.s.p.DmaapProducerReactiveHttpClient : Starting to publish to DR
2018-10-11 09:48:20.916 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ===========================request begin================================================
2018-10-11 09:48:20.916 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : URI         : https://localhost:3907/publish/1/fileFromSftp.tar.gz
2018-10-11 09:48:20.916 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Method      : PUT
2018-10-11 09:48:20.916 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Headers     : {Accept=[text/plain, application/json, application/*+json, */*], Content-Type=[application/octet-stream], X-ATT-DR-META=[{"compression":"gzip","fileFormatType":"org.3GPP.32.435#measCollec","fileFormatVersion":"V10"}], Authorization=[Basic ZHJhZG1pbjpkcmFkbWlu], Content-Length=[10240]}
2018-10-11 09:48:20.916 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Request body: fileFromSftp.txt0000644000000000000000000000003413336534767012733 0ustar  rootrootdummy text from ftps server

2018-10-11 09:48:20.916 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ==========================request end================================================
2018-10-11 09:48:20.926 DEBUG 2387 --- [reactor-http-nio-4] o.o.d.c.d.web.PublishRedirectStrategy    : Redirect requested to location 'http://127.0.0.1:3908/publish/1/fileFromSftp.tar.gz'
2018-10-11 09:48:20.926 TRACE 2387 --- [reactor-http-nio-4] o.o.d.c.d.web.PublishRedirectStrategy    : getRedirect...: PUT https://localhost:3907/publish/1/fileFromSftp.tar.gz HTTP/1.1
2018-10-11 09:48:20.929 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : ============================response begin==========================================
2018-10-11 09:48:20.929 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Status code  : 200
2018-10-11 09:48:20.929 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Status text  : OK
2018-10-11 09:48:20.929 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : Headers      : {X-Powered-By=[Express], Content-Type=[text/html; charset=utf-8], Content-Length=[2], ETag=[W/"2-eoX0dku9ba8cNUXvu/DyeabcC+s"], Date=[Thu, 11 Oct 2018 07:48:20 GMT], Connection=[keep-alive]}
2018-10-11 09:48:20.929 DEBUG 2387 --- [reactor-http-nio-4] .c.d.w.RequestResponseLoggingInterceptor : =======================response end=================================================
2018-10-11 09:48:20.929  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile consumed tasks. HTTP Response code 200
2018-10-11 09:48:20.929  INFO 2387 --- [reactor-http-nio-4] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile tasks have been completed
2018-10-11 09:48:29.991 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.datafile.tasks.ScheduledTasks    : Execution of tasks was registered
2018-10-11 09:48:30.008 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.tasks.DmaapConsumerTaskImpl    : execute called with arg 
2018-10-11 09:48:30.008 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : Request: GET http://localhost:2222/events/unauthenticated.VES_NOTIFICATION_OUTPUT/OpenDcae-c12/C12
2018-10-11 09:48:30.009  INFO 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : Content-Type=application/json
2018-10-11 09:48:30.009 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.s.DmaapReactiveWebClient       : HTTP request headers: {Content-Type=[application/json]}
2018-10-11 09:48:30.009 TRACE 2387 --- [pool-2-thread-1] o.o.d.c.d.tasks.DmaapConsumerTaskImpl    : consume called with arg MonoFlatMap
2018-10-11 09:48:30.012 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapReactiveWebClient       : Response Status 200
2018-10-11 09:48:30.016 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapConsumerJsonParser      : original message from message router: 
["{\"event\":{\"commonEventHeader\":{\"startEpochMicrosec\":0000000000000,\"eventId\":\"FileReady_1797490e-10ae-4d48-9ea7-3d7d790b25e1\",\"timeZoneOffset\":\"UTC+05.30\",\"internalHeaderFields\":{\"collectorTimeStamp\":\"Wed, 09 19 2018 11:39:30 UTC\"},\"priority\":\"Normal\",\"version\":\"4.0.1\",\"reportingEntityName\":\"otenb5309\",\"sequence\":0,\"domain\":\"notification\",\"lastEpochMicrosec\":8745745764578,\"eventName\":\"Noti_RnNode-Ericsson_FileReady\",\"vesEventListenerVersion\":\"7.0.1\",\"sourceName\":\"oteNB5309\"},\"notificationFields\":{\"notificationFieldsVersion\":\"2.0\",\"changeType\":\"FileReady\",\"changeIdentifier\":\"PM_MEAS_FILES\",\"arrayOfNamedHashMap\":[{\"name\":\"fileFromFtps.tar.gz\",\"hashMap\":{\"location\":\"ftpes://myuser:mypass@localhost:21/fileFromFtps.tar.gz\",\"fileFormatType\":\"org.3GPP.32.435#measCollec\",\"fileFormatVersion\":\"V10\",\"compression\":\"gzip\"}},
{\"name\":\"fileFromSftp.tar.gz\",\"hashMap\":{\"location\":\"sftp://foo:pass@localhost:22/fileFromSftp.tar.gz\",\"fileFormatType\":\"org.3GPP.32.435#measCollec\",\"fileFormatVersion\":\"V10\",\"compression\":\"gzip\"}}]}}}"]

2018-10-11 09:48:30.016 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getJsonObjectFromAnArray!
2018-10-11 09:48:30.016 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getFileDataFromJson!
2018-10-11 09:48:30.016 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.s.DmaapConsumerJsonParser      : starting to getFileDataFromJson!
2018-10-11 09:48:30.016 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Entering execute with FileData{changeIdentifier=PM_MEAS_FILES, changeType=FileReady, name=fileFromFtps.tar.gz, location=ftpes://myuser:mypass@localhost:21/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:30.017 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : starting to collectFile
2018-10-11 09:48:30.017 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : collectFile called with fileServerData: FileServerData{serverAddress=localhost, userId=myuser, password=mypass, port=21}, remoteFile: /fileFromFtps.tar.gz, localFile: target/fileFromFtps.tar.gz
2018-10-11 09:48:30.017 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile called
2018-10-11 09:48:30.221  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : complete setUpKeyManager
2018-10-11 09:48:30.222  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : complete setUpTrustedCA
2018-10-11 09:48:30.242  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : after ftp connect
2018-10-11 09:48:30.255 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : setUpConnection return value: true
2018-10-11 09:48:30.255 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : starting to getFile
2018-10-11 09:48:30.355 DEBUG 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : File target/fileFromFtps.tar.gz Download Successfull from xNF
2018-10-11 09:48:30.356 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : starting to closeDownConnection
2018-10-11 09:48:30.357 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : collectFile left with result: Download successful: true Error data: , errorData: 
2018-10-11 09:48:30.358 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Exiting execute with ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:30.358 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.DmaapPublisherTaskImpl   : Method called with arg ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:30.358 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : Entering getDmaapProducerResponse with ConsumerDmaapModel{name=fileFromFtps.tar.gz, location=target/fileFromFtps.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:30.358 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : base64Creds...: ZHJhZG1pbjpkcmFkbWlu
2018-10-11 09:48:30.358 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : Starting to publish to DR
2018-10-11 09:48:30.366 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ===========================request begin================================================
2018-10-11 09:48:30.366 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : URI         : https://localhost:3907/publish/1/fileFromFtps.tar.gz
2018-10-11 09:48:30.366 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Method      : PUT
2018-10-11 09:48:30.366 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Headers     : {Accept=[text/plain, application/json, application/*+json, */*], Content-Type=[application/octet-stream], X-ATT-DR-META=[{"compression":"gzip","fileFormatType":"org.3GPP.32.435#measCollec","fileFormatVersion":"V10"}], Authorization=[Basic ZHJhZG1pbjpkcmFkbWlu], Content-Length=[793]}
2018-10-11 09:48:30.366 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Request body: ?H?[???ON-*?M+)(???.f?>000031Q??f?`???#ccCcc##cS3CSS???$
?????????Y???UPYZs ^Q??C???3010?&&+?+D(@
H?????8?A????e?tL
bv4%?q???\??????"???T`dX?X??%?G<?u?
???
???h??????[H?f??
I?????5B???(9??i?A?&N??	A
?Yw/6?e??j?h???????`??k?m?????&??j(d ?p?p??;{{???????x
?Ab\<,>n!
??@s?\n6gOW?C
>?3{j28?U??Vs2???&?d??%?
%R?K?JR?3??y
-,???????2
?D?:?6?GQFV??^`?v2562??:???^??Z?G]?????z?go??FqR?K?ym?,??~?????s,??9????>|:s?s??&	??}?M?[6?`???SG?5sg?8?S}3???0?&Af??+???<6O???J?r???L??h?tW?;??L??9?y&5?1|??a}8?)3?yi~Ym???_i?|??7.u?xg?cu??d?E?m?o??{??
W?
??????z?????bA?|[??????j??E????K?W????v???d's???6?<?O?2??(?8?????}3???8_??Q0
F?(?`??Q0
F?(?`??Q0
F?(?`??Q0
F?(???%(
2018-10-11 09:48:30.366 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ==========================request end================================================
2018-10-11 09:48:30.377 DEBUG 2387 --- [reactor-http-nio-2] o.o.d.c.d.web.PublishRedirectStrategy    : Redirect requested to location 'http://127.0.0.1:3908/publish/1/fileFromFtps.tar.gz'
2018-10-11 09:48:30.378 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.web.PublishRedirectStrategy    : getRedirect...: PUT https://localhost:3907/publish/1/fileFromFtps.tar.gz HTTP/1.1
2018-10-11 09:48:30.380 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ============================response begin==========================================
2018-10-11 09:48:30.380 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Status code  : 200
2018-10-11 09:48:30.380 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Status text  : OK
2018-10-11 09:48:30.380 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Headers      : {X-Powered-By=[Express], Content-Type=[text/html; charset=utf-8], Content-Length=[2], ETag=[W/"2-eoX0dku9ba8cNUXvu/DyeabcC+s"], Date=[Thu, 11 Oct 2018 07:48:30 GMT], Connection=[keep-alive]}
2018-10-11 09:48:30.380 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : =======================response end=================================================
2018-10-11 09:48:30.381  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile consumed tasks. HTTP Response code 200
2018-10-11 09:48:30.381 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Entering execute with FileData{changeIdentifier=PM_MEAS_FILES, changeType=FileReady, name=fileFromSftp.tar.gz, location=sftp://foo:pass@localhost:22/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:30.381 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : starting to collectFile
2018-10-11 09:48:30.381 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : collectFile called with fileServerData: FileServerData{serverAddress=localhost, userId=foo, password=pass, port=22}, remoteFile: /fileFromSftp.tar.gz, localFile: target/fileFromSftp.tar.gz
2018-10-11 09:48:30.381 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile called
2018-10-11 09:48:30.985 DEBUG 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : File fileFromSftp.tar.gz Download Successfull from xNF
2018-10-11 09:48:30.987 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.ftp.FtpsClient          : retryCollectFile left with result: Download successful: true Error data: 
2018-10-11 09:48:30.987 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.XnfCollectorTaskImpl     : Exiting execute with ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:30.987 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.tasks.DmaapPublisherTaskImpl   : Method called with arg ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:30.987 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : Entering getDmaapProducerResponse with ConsumerDmaapModel{name=fileFromSftp.tar.gz, location=target/fileFromSftp.tar.gz, compression=gzip, fileFormatType=org.3GPP.32.435#measCollec, fileFormatVersion=V10}
2018-10-11 09:48:30.988 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : base64Creds...: ZHJhZG1pbjpkcmFkbWlu
2018-10-11 09:48:30.989 TRACE 2387 --- [reactor-http-nio-2] .c.d.s.p.DmaapProducerReactiveHttpClient : Starting to publish to DR
2018-10-11 09:48:30.995 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ===========================request begin================================================
2018-10-11 09:48:30.995 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : URI         : https://localhost:3907/publish/1/fileFromSftp.tar.gz
2018-10-11 09:48:30.995 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Method      : PUT
2018-10-11 09:48:30.995 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Headers     : {Accept=[text/plain, application/json, application/*+json, */*], Content-Type=[application/octet-stream], X-ATT-DR-META=[{"compression":"gzip","fileFormatType":"org.3GPP.32.435#measCollec","fileFormatVersion":"V10"}], Authorization=[Basic ZHJhZG1pbjpkcmFkbWlu], Content-Length=[10240]}
2018-10-11 09:48:30.995 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Request body: fileFromSftp.txt0000644000000000000000000000003413336534767012733 0ustar  rootrootdummy text from ftps server

2018-10-11 09:48:30.995 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ==========================request end================================================
2018-10-11 09:48:31.003 DEBUG 2387 --- [reactor-http-nio-2] o.o.d.c.d.web.PublishRedirectStrategy    : Redirect requested to location 'http://127.0.0.1:3908/publish/1/fileFromSftp.tar.gz'
2018-10-11 09:48:31.003 TRACE 2387 --- [reactor-http-nio-2] o.o.d.c.d.web.PublishRedirectStrategy    : getRedirect...: PUT https://localhost:3907/publish/1/fileFromSftp.tar.gz HTTP/1.1
2018-10-11 09:48:31.005 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : ============================response begin==========================================
2018-10-11 09:48:31.005 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Status code  : 200
2018-10-11 09:48:31.005 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Status text  : OK
2018-10-11 09:48:31.005 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : Headers      : {X-Powered-By=[Express], Content-Type=[text/html; charset=utf-8], Content-Length=[2], ETag=[W/"2-eoX0dku9ba8cNUXvu/DyeabcC+s"], Date=[Thu, 11 Oct 2018 07:48:31 GMT], Connection=[keep-alive]}
2018-10-11 09:48:31.005 DEBUG 2387 --- [reactor-http-nio-2] .c.d.w.RequestResponseLoggingInterceptor : =======================response end=================================================
2018-10-11 09:48:31.005  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile consumed tasks. HTTP Response code 200
2018-10-11 09:48:31.005  INFO 2387 --- [reactor-http-nio-2] o.o.d.c.datafile.tasks.ScheduledTasks    : Datafile tasks have been completed