Skip to content

Instantly share code, notes, and snippets.

@omerholz

omerholz/log-sink_stdout_0.log Secret

Created December 21, 2017 18:00
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save omerholz/aedb2245f3230eacc4e96a506e57fcfa to your computer and use it in GitHub Desktop.
Save omerholz/aedb2245f3230eacc4e96a506e57fcfa to your computer and use it in GitHub Desktop.
Download ZIP
Raw
log-sink_stdout_0.log
2017-12-21 11:58:01.625 DEBUG 86502 --- [ -L-1] o.s.integration.channel.DirectChannel : postSend (sent=true) on channel 'input', message: GenericMessage [payload=byte[383072], headers={kafka_offset=24, id=b84f89e7-050f-4d87-0c14-dcd284938947, kafka_receivedPartitionId=0, contentType=application/octet-stream, kafka_receivedTopic=test_sftp_log.sftp-source, timestamp=1513875481624}]
2017-12-21 11:58:52.901 DEBUG 86502 --- [ -L-1] o.s.integration.channel.DirectChannel : preSend on channel 'input', message: GenericMessage [payload=byte[228], headers={kafka_offset=25, id=db1a4014-298b-7481-cb08-ffffe61c2f1f, kafka_receivedPartitionId=0, contentType=application/octet-stream, kafka_receivedTopic=test_sftp_log.sftp-source, timestamp=1513875532901}]
2017-12-21 11:58:52.901 DEBUG 86502 --- [ -L-1] ssor$ReplyProducingMessageHandlerWrapper : org.springframework.cloud.stream.app.log.sink.LogSinkConfiguration.logSinkHandler.serviceActivator.handler received message: GenericMessage [payload=byte[228], headers={kafka_offset=25, id=db1a4014-298b-7481-cb08-ffffe61c2f1f, kafka_receivedPartitionId=0, contentType=application/octet-stream, kafka_receivedTopic=test_sftp_log.sftp-source, timestamp=1513875532901}]
2017-12-21 11:58:52.901 DEBUG 86502 --- [ -L-1] o.s.integration.handler.LoggingHandler : logSinkHandler received message: GenericMessage [payload=byte[228], headers={kafka_offset=25, id=db1a4014-298b-7481-cb08-ffffe61c2f1f, kafka_receivedPartitionId=0, contentType=application/octet-stream, kafka_receivedTopic=test_sftp_log.sftp-source, timestamp=1513875532901}]
2017-12-21 11:58:52.901 INFO 86502 --- [ -L-1] log-sink : [B@602c094c
2017-12-21 11:58:52.901 DEBUG 86502 --- [ -L-1] ssor$ReplyProducingMessageHandlerWrapper : handler 'org.springframework.cloud.stream.app.log.sink.LogSinkConfiguration.logSinkHandler.serviceActivator.handler' produced no reply for request Message: GenericMessage [payload=byte[228], headers={kafka_offset=25, id=db1a4014-298b-7481-cb08-ffffe61c2f1f, kafka_receivedPartitionId=0, contentType=application/octet-stream, kafka_receivedTopic=test_sftp_log.sftp-source, timestamp=1513875532901}]
2017-12-21 11:58:52.902 DEBUG 86502 --- [ -L-1] o.s.integration.channel.DirectChannel : postSend (sent=true) on channel 'input', message: GenericMessage [payload=byte[228], headers={kafka_offset=25, id=db1a4014-298b-7481-cb08-ffffe61c2f1f, kafka_receivedPartitionId=0, contentType=application/octet-stream, kafka_receivedTopic=test_sftp_log.sftp-source, timestamp=1513875532901}]
Raw
sftp-source_stdout_0.log
cat /var/folders/vk/l81k664n0rn42dj9w5g3rr2w0000gn/T/spring-cloud-dataflow-8128040869817285500/test_sftp_log-1513875128478/test_sftp_log.sftp-source/stdout_0.log | grep my_test_file.csv
2017-12-21 11:57:55.506 DEBUG 86503 --- [ask-scheduler-1] o.s.i.e.SourcePollingChannelAdapter : Poll resulted in Message: GenericMessage [payload=com.jcraft.jsch.ChannelSftp$2@77ef0b53, headers={closableResource=org.springframework.integration.sftp.session.SftpSession@35041453, id=fb6e361f-b3c4-3ac1-c8ef-e7cba10078a8, file_remoteDirectory=/incoming, file_remoteFile=my_test_file.csv, timestamp=1513875475506}]
2017-12-21 11:57:55.506 DEBUG 86503 --- [ask-scheduler-1] o.s.integration.channel.DirectChannel : preSend on channel 'sftpInboundFlow.channel#0', message: GenericMessage [payload=com.jcraft.jsch.ChannelSftp$2@77ef0b53, headers={closableResource=org.springframework.integration.sftp.session.SftpSession@35041453, id=fb6e361f-b3c4-3ac1-c8ef-e7cba10078a8, file_remoteDirectory=/incoming, file_remoteFile=my_test_file.csv, timestamp=1513875475506}]
2017-12-21 11:57:55.506 DEBUG 86503 --- [ask-scheduler-1] o.s.i.t.MessageTransformingHandler : org.springframework.integration.transformer.MessageTransformingHandler#0 received message: GenericMessage [payload=com.jcraft.jsch.ChannelSftp$2@77ef0b53, headers={closableResource=org.springframework.integration.sftp.session.SftpSession@35041453, id=fb6e361f-b3c4-3ac1-c8ef-e7cba10078a8, file_remoteDirectory=/incoming, file_remoteFile=my_test_file.csv, timestamp=1513875475506}]
2017-12-21 11:57:55.506 DEBUG 86503 --- [ask-scheduler-1] o.s.integration.channel.DirectChannel : preSend on channel 'sftpInboundFlow.channel#1', message: GenericMessage [payload=com.jcraft.jsch.ChannelSftp$2@77ef0b53, headers={closableResource=org.springframework.integration.sftp.session.SftpSession@35041453, id=fb0c92bf-659c-5f53-fe92-84a664b70c89, contentType=application/octet-stream, file_remoteDirectory=/incoming, file_remoteFile=my_test_file.csv, timestamp=1513875475506}]
2017-12-21 11:57:55.506 DEBUG 86503 --- [ask-scheduler-1] o.s.i.t.MessageTransformingHandler : org.springframework.integration.transformer.MessageTransformingHandler#1 received message: GenericMessage [payload=com.jcraft.jsch.ChannelSftp$2@77ef0b53, headers={closableResource=org.springframework.integration.sftp.session.SftpSession@35041453, id=fb0c92bf-659c-5f53-fe92-84a664b70c89, contentType=application/octet-stream, file_remoteDirectory=/incoming, file_remoteFile=my_test_file.csv, timestamp=1513875475506}]
2017-12-21 11:57:55.752 DEBUG 86503 --- [ask-scheduler-1] o.s.integration.channel.DirectChannel : preSend on channel 'output', message: GenericMessage [payload=byte[943387], headers={closableResource=org.springframework.integration.sftp.session.SftpSession@35041453, id=76f16e13-53d0-409c-7f55-e8c3ed1bb305, contentType=application/octet-stream, file_remoteDirectory=/incoming, file_remoteFile=my_test_file.csv, timestamp=1513875475752}]
2017-12-21 11:57:55.755 DEBUG 86503 --- [ask-scheduler-1] o.s.integration.channel.DirectChannel : postSend (sent=true) on channel 'output', message: GenericMessage [payload=byte[943387], headers={closableResource=org.springframework.integration.sftp.session.SftpSession@35041453, id=76f16e13-53d0-409c-7f55-e8c3ed1bb305, contentType=application/octet-stream, file_remoteDirectory=/incoming, file_remoteFile=my_test_file.csv, timestamp=1513875475752}]
2017-12-21 11:57:55.755 DEBUG 86503 --- [ask-scheduler-1] o.s.integration.channel.DirectChannel : postSend (sent=true) on channel 'sftpInboundFlow.channel#1', message: GenericMessage [payload=com.jcraft.jsch.ChannelSftp$2@77ef0b53, headers={closableResource=org.springframework.integration.sftp.session.SftpSession@35041453, id=fb0c92bf-659c-5f53-fe92-84a664b70c89, contentType=application/octet-stream, file_remoteDirectory=/incoming, file_remoteFile=my_test_file.csv, timestamp=1513875475506}]
2017-12-21 11:57:55.755 DEBUG 86503 --- [ask-scheduler-1] o.s.integration.channel.DirectChannel : postSend (sent=true) on channel 'sftpInboundFlow.channel#0', message: GenericMessage [payload=com.jcraft.jsch.ChannelSftp$2@77ef0b53, headers={closableResource=org.springframework.integration.sftp.session.SftpSession@35041453, id=fb6e361f-b3c4-3ac1-c8ef-e7cba10078a8, file_remoteDirectory=/incoming, file_remoteFile=my_test_file.csv, timestamp=1513875475506}]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment