You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Igor Ivaniuk (JIRA)" <ji...@apache.org> on 2013/04/03 16:45:16 UTC
[jira] [Comment Edited] (CAMEL-6231) Camel Split doesn't processes
the payload of the file, received via FTP
[ https://issues.apache.org/jira/browse/CAMEL-6231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13620962#comment-13620962 ]
Igor Ivaniuk edited comment on CAMEL-6231 at 4/3/13 2:44 PM:
-------------------------------------------------------------
There are no errors in Camel log at all.
Here is the debug output in Camel log, that appears on processing the file from FTP. Sorry for log this big:
{noformat}
2013-04-03T10:28:20.290-0500|INFO |Thread:Thread-27|org.apache.camel.spring.SpringCamelContext - Total 1 routes, of which 1 is started.
2013-04-03T10:28:20.290-0500|INFO |Thread:Thread-27|org.apache.camel.spring.SpringCamelContext - Apache Camel 2.10.4-SNAPSHOT (CamelContext: receiveFTP) started in 1.141 seconds
2013-04-03T10:28:21.305-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpConsumer - Not connected/logged in, connecting to: ftp://idstest@192.168.21.11:21
2013-04-03T10:28:21.524-0500|INFO |Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpConsumer - Connected and logged in to: ftp://idstest@192.168.21.11:21
2013-04-03T10:28:21.743-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpConsumer - Took 0.219 seconds to poll: ids/
2013-04-03T10:28:21.743-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpConsumer - Total 1 files to consume
2013-04-03T10:28:21.743-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpOperations - Renaming file: ids/FTP_ftpTest.txt_20130403102739040.txt to: ids//FTP_ftpTest.txt_20130403102739040.txt.camelExclusiveReadLock
2013-04-03T10:28:21.759-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpOperations - Renaming file: ids//FTP_ftpTest.txt_20130403102739040.txt.camelExclusiveReadLock to: ids/FTP_ftpTest.txt_20130403102739040.txt
2013-04-03T10:28:21.759-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.util.FileUtil - Retrying attempt 0 to delete file: ..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt
2013-04-03T10:28:21.759-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.util.FileUtil - Tried 1 to delete file: ..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt with result: true
2013-04-03T10:28:21.993-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpOperations - Retrieve file to local work file result: true
2013-04-03T10:28:21.993-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.util.FileUtil - Tried 1 to rename file: ..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt.inprogress to: ..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt with result: true
2013-04-03T10:28:21.993-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpConsumer - About to process file: RemoteFile[FTP_ftpTest.txt_20130403102739040.txt] using exchange: Exchange[FTP_ftpTest.txt_20130403102739040.txt]
2013-04-03T10:28:21.993-0500|INFO |Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|ExchangeTracer - ID-INDIGO5-59921-1365002690852-4-2 >>> (ReceiveFromFTP) from(ftp://192.168.21.11:21/ids/?binary=false&consumer.bridgeErrorHandler=true&delay=1000&delete=true&include=.*%5C.txt&localWorkDirectory=..%2F..%2Fids_temp%2F&maxMessagesPerPoll=100&moveFailed=.failed&passiveMode=true&password=1ds%23%232013&pollStrategy=%23ftpPollStrategy&readLock=rename&throwExceptionOnConnectFailed=true&username=idstest) --> pipeline <<< Pattern:InOnly, Headers:{CamelFilePath=ids//FTP_ftpTest.txt_20130403102739040.txt, CamelFileName=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLastModified=1365002520000, CamelFileHost=192.168.21.11, breadcrumbId=ID-INDIGO5-59921-1365002690852-4-1, CamelFileAbsolute=false, CamelFileParent=ids, CamelFileNameOnly=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLocalWorkPath=..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt, CamelFileRelativePath=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLength=141, CamelFileAbsolutePath=ids/FTP_ftpTest.txt_20130403102739040.txt}, BodyType:org.apache.camel.component.file.remote.RemoteFile, Body:[Body is file based: RemoteFile[FTP_ftpTest.txt_20130403102739040.txt]]
2013-04-03T10:28:21.993-0500|INFO |Thread:Camel (receiveFTP) thread #15 - Threads|ExchangeTracer - ID-INDIGO5-59921-1365002690852-4-2 >>> (ReceiveFromFTP) pipeline --> split[tokenize(body, \r\n)] <<< Pattern:InOnly, Headers:{CamelFilePath=ids//FTP_ftpTest.txt_20130403102739040.txt, CamelFileName=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLastModified=1365002520000, CamelFileHost=192.168.21.11, breadcrumbId=ID-INDIGO5-59921-1365002690852-4-1, CamelFileAbsolute=false, CamelFileParent=ids, CamelFileNameOnly=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLocalWorkPath=..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt, CamelFileRelativePath=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLength=141, CamelFileAbsolutePath=ids/FTP_ftpTest.txt_20130403102739040.txt}, BodyType:org.apache.camel.component.file.remote.RemoteFile, Body:[Body is file based: RemoteFile[FTP_ftpTest.txt_20130403102739040.txt]]
2013-04-03T10:28:22.024-0500|DEBUG|Thread:Camel (receiveFTP) thread #15 - Threads|org.apache.camel.processor.DefaultErrorHandler - Redelivery enabled: true on error handler: DefaultErrorHandler[Channel[sendTo(Endpoint[file://D:/Temp/ids-test/ftpReceive/?fileName=Received_%24%7BexchangeId%7D_%24%7Bfile%3Aonlyname%7D])]]
2013-04-03T10:28:22.040-0500|DEBUG|Thread:Camel (receiveFTP) thread #15 - Threads|org.apache.camel.processor.MulticastProcessor - Waiting for on-the-fly aggregation to complete aggregating 1 responses for exchangeId: ID-INDIGO5-59921-1365002690852-4-2
2013-04-03T10:28:22.040-0500|INFO |Thread:Camel (receiveFTP) thread #16 - Split|ExchangeTracer - ID-INDIGO5-59921-1365002690852-4-3 >>> (ReceiveFromFTP) from(ftp://192.168.21.11:21/ids/?binary=false&consumer.bridgeErrorHandler=true&delay=1000&delete=true&include=.*%5C.txt&localWorkDirectory=..%2F..%2Fids_temp%2F&maxMessagesPerPoll=100&moveFailed=.failed&passiveMode=true&password=1ds%23%232013&pollStrategy=%23ftpPollStrategy&readLock=rename&throwExceptionOnConnectFailed=true&username=idstest) --> file://D:/Temp/ids-test/ftpReceive/?fileName=Received_%24%7BexchangeId%7D_%24%7Bfile%3Aonlyname%7D <<< Pattern:InOnly, Headers:{CamelFileRelativePath=FTP_ftpTest.txt_20130403102739040.txt, CamelFileHost=192.168.21.11, CamelFileLength=141, CamelFileAbsolute=false, breadcrumbId=ID-INDIGO5-59921-1365002690852-4-1, CamelFileParent=ids, CamelFileLocalWorkPath=..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt, CamelFileName=FTP_ftpTest.txt_20130403102739040.txt, CamelFileNameOnly=FTP_ftpTest.txt_20130403102739040.txt, CamelFileAbsolutePath=ids/FTP_ftpTest.txt_20130403102739040.txt, CamelFilePath=ids//FTP_ftpTest.txt_20130403102739040.txt, CamelFileLastModified=1365002520000}, BodyType:String, Body:-rw-r--r-- 1 ftp ftp 141 Apr 03 10:22 FTP_ftpTest.txt_20130403102739040.txt
2013-04-03T10:28:22.040-0500|DEBUG|Thread:Camel (receiveFTP) thread #16 - Split|org.apache.camel.processor.SendProcessor - >>>> Endpoint[file://D:/Temp/ids-test/ftpReceive/?fileName=Received_%24%7BexchangeId%7D_%24%7Bfile%3Aonlyname%7D] Exchange[null]
2013-04-03T10:28:22.040-0500|DEBUG|Thread:Camel (receiveFTP) thread #16 - Split|org.apache.camel.component.file.FileOperations - Using InputStream to write file: D:\Temp\ids-test\ftpReceive\Received_ID-INDIGO5-59921-1365002690852-4-3_FTP_ftpTest.txt_20130403102739040.txt
2013-04-03T10:28:22.118-0500|DEBUG|Thread:Camel (receiveFTP) thread #16 - Split|org.apache.camel.component.file.GenericFileProducer - Wrote [D:\Temp\ids-test\ftpReceive\Received_ID-INDIGO5-59921-1365002690852-4-3_FTP_ftpTest.txt_20130403102739040.txt] to [Endpoint[file://D:/Temp/ids-test/ftpReceive/?fileName=Received_%24%7BexchangeId%7D_%24%7Bfile%3Aonlyname%7D]]
2013-04-03T10:28:22.118-0500|INFO |Thread:Camel (receiveFTP) thread #16 - Split|ExchangeTracer - ID-INDIGO5-59921-1365002690852-4-3 >>> (ReceiveFromFTP) from(ftp://192.168.21.11:21/ids/?binary=false&consumer.bridgeErrorHandler=true&delay=1000&delete=true&include=.*%5C.txt&localWorkDirectory=..%2F..%2Fids_temp%2F&maxMessagesPerPoll=100&moveFailed=.failed&passiveMode=true&password=1ds%23%232013&pollStrategy=%23ftpPollStrategy&readLock=rename&throwExceptionOnConnectFailed=true&username=idstest) --> file://D:/Temp/ids-test/ftpReceive/?fileName=Received_%24%7BexchangeId%7D_%24%7Bfile%3Aonlyname%7D <<< Pattern:InOnly, Headers:{CamelFileNameProduced=D:\Temp\ids-test\ftpReceive\Received_ID-INDIGO5-59921-1365002690852-4-3_FTP_ftpTest.txt_20130403102739040.txt, CamelFileAbsolutePath=ids/FTP_ftpTest.txt_20130403102739040.txt, CamelFileNameOnly=FTP_ftpTest.txt_20130403102739040.txt, CamelFileParent=ids, CamelFileHost=192.168.21.11, CamelFileRelativePath=FTP_ftpTest.txt_20130403102739040.txt, CamelFileAbsolute=false, CamelFileLocalWorkPath=..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt, CamelFileLastModified=1365002520000, breadcrumbId=ID-INDIGO5-59921-1365002690852-4-1, CamelFilePath=ids//FTP_ftpTest.txt_20130403102739040.txt, CamelFileLength=141, CamelFileName=FTP_ftpTest.txt_20130403102739040.txt}, BodyType:String, Body:-rw-r--r-- 1 ftp ftp 141 Apr 03 10:22 FTP_ftpTest.txt_20130403102739040.txt
2013-04-03T10:28:22.180-0500|INFO |Thread:pool-15-thread-1|com.it.ids.gui.delegates.admin.AccountManagementDelegate - Successfully loaded customers to user-interface table.
2013-04-03T10:28:22.321-0500|DEBUG|Thread:Camel (receiveFTP) thread #17 - Splitter-AggregateTask|org.apache.camel.processor.MulticastProcessor - Done aggregating 1 exchanges on the fly.
2013-04-03T10:28:22.321-0500|DEBUG|Thread:Camel (receiveFTP) thread #17 - Splitter-AggregateTask|org.apache.camel.processor.MulticastProcessor - Signaling we are done aggregating on the fly for exchangeId: ID-INDIGO5-59921-1365002690852-4-2
2013-04-03T10:28:22.321-0500|DEBUG|Thread:Camel (receiveFTP) thread #15 - Threads|org.apache.camel.processor.MulticastProcessor - Done parallel processing 1 exchanges
2013-04-03T10:28:22.321-0500|INFO |Thread:Camel (receiveFTP) thread #15 - Threads|ExchangeTracer - ID-INDIGO5-59921-1365002690852-4-2 >>> (ReceiveFromFTP) pipeline --> split[tokenize(body, \r\n)] <<< Pattern:InOnly, Headers:{CamelFilePath=ids//FTP_ftpTest.txt_20130403102739040.txt, CamelFileName=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLastModified=1365002520000, CamelFileHost=192.168.21.11, breadcrumbId=ID-INDIGO5-59921-1365002690852-4-1, CamelFileAbsolute=false, CamelFileParent=ids, CamelFileNameOnly=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLocalWorkPath=..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt, CamelFileRelativePath=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLength=141, CamelFileAbsolutePath=ids/FTP_ftpTest.txt_20130403102739040.txt}, BodyType:org.apache.camel.component.file.remote.RemoteFile, Body:[Body is file based: RemoteFile[FTP_ftpTest.txt_20130403102739040.txt]]
2013-04-03T10:28:22.477-0500|INFO |Thread:Camel (receiveFTP) thread #15 - Threads|ExchangeTracer - ID-INDIGO5-59921-1365002690852-4-2 >>> (ReceiveFromFTP) pipeline --> split[tokenize(body, \r\n)] <<< Pattern:InOnly, Headers:{CamelFilePath=ids//FTP_ftpTest.txt_20130403102739040.txt, CamelFileName=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLastModified=1365002520000, CamelFileHost=192.168.21.11, breadcrumbId=ID-INDIGO5-59921-1365002690852-4-1, CamelFileAbsolute=false, CamelFileParent=ids, CamelFileNameOnly=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLocalWorkPath=..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt, CamelFileRelativePath=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLength=141, CamelFileAbsolutePath=ids/FTP_ftpTest.txt_20130403102739040.txt}, BodyType:org.apache.camel.component.file.remote.RemoteFile, Body:[Body is file based: RemoteFile[FTP_ftpTest.txt_20130403102739040.txt]]
2013-04-03T10:28:22.477-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.GenericFileOnCompletion - Done processing file: RemoteFile[FTP_ftpTest.txt_20130403102739040.txt] using exchange: Exchange[FTP_ftpTest.txt_20130403102739040.txt]
{noformat}
On receiving FTP file, the BodyType is *BodyType:org.apache.camel.component.file.remote.RemoteFile*
After starting Split - *BodyType:String*.
This is all I can read from the log.
was (Author: igor.ivaniuk@intellecteu.com):
There are no errors in Camel log at all.
Here is the debug output in Camel log, that appears on processing the file from FTP. Sorry for log this big:
2013-04-03T10:28:20.290-0500|INFO |Thread:Thread-27|org.apache.camel.spring.SpringCamelContext - Total 1 routes, of which 1 is started.
2013-04-03T10:28:20.290-0500|INFO |Thread:Thread-27|org.apache.camel.spring.SpringCamelContext - Apache Camel 2.10.4-SNAPSHOT (CamelContext: receiveFTP) started in 1.141 seconds
2013-04-03T10:28:21.305-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpConsumer - Not connected/logged in, connecting to: ftp://idstest@192.168.21.11:21
2013-04-03T10:28:21.524-0500|INFO |Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpConsumer - Connected and logged in to: ftp://idstest@192.168.21.11:21
2013-04-03T10:28:21.743-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpConsumer - Took 0.219 seconds to poll: ids/
2013-04-03T10:28:21.743-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpConsumer - Total 1 files to consume
2013-04-03T10:28:21.743-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpOperations - Renaming file: ids/FTP_ftpTest.txt_20130403102739040.txt to: ids//FTP_ftpTest.txt_20130403102739040.txt.camelExclusiveReadLock
2013-04-03T10:28:21.759-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpOperations - Renaming file: ids//FTP_ftpTest.txt_20130403102739040.txt.camelExclusiveReadLock to: ids/FTP_ftpTest.txt_20130403102739040.txt
2013-04-03T10:28:21.759-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.util.FileUtil - Retrying attempt 0 to delete file: ..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt
2013-04-03T10:28:21.759-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.util.FileUtil - Tried 1 to delete file: ..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt with result: true
2013-04-03T10:28:21.993-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpOperations - Retrieve file to local work file result: true
2013-04-03T10:28:21.993-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.util.FileUtil - Tried 1 to rename file: ..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt.inprogress to: ..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt with result: true
2013-04-03T10:28:21.993-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.remote.FtpConsumer - About to process file: RemoteFile[FTP_ftpTest.txt_20130403102739040.txt] using exchange: Exchange[FTP_ftpTest.txt_20130403102739040.txt]
2013-04-03T10:28:21.993-0500|INFO |Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|ExchangeTracer - ID-INDIGO5-59921-1365002690852-4-2 >>> (ReceiveFromFTP) from(ftp://192.168.21.11:21/ids/?binary=false&consumer.bridgeErrorHandler=true&delay=1000&delete=true&include=.*%5C.txt&localWorkDirectory=..%2F..%2Fids_temp%2F&maxMessagesPerPoll=100&moveFailed=.failed&passiveMode=true&password=1ds%23%232013&pollStrategy=%23ftpPollStrategy&readLock=rename&throwExceptionOnConnectFailed=true&username=idstest) --> pipeline <<< Pattern:InOnly, Headers:{CamelFilePath=ids//FTP_ftpTest.txt_20130403102739040.txt, CamelFileName=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLastModified=1365002520000, CamelFileHost=192.168.21.11, breadcrumbId=ID-INDIGO5-59921-1365002690852-4-1, CamelFileAbsolute=false, CamelFileParent=ids, CamelFileNameOnly=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLocalWorkPath=..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt, CamelFileRelativePath=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLength=141, CamelFileAbsolutePath=ids/FTP_ftpTest.txt_20130403102739040.txt}, BodyType:org.apache.camel.component.file.remote.RemoteFile, Body:[Body is file based: RemoteFile[FTP_ftpTest.txt_20130403102739040.txt]]
2013-04-03T10:28:21.993-0500|INFO |Thread:Camel (receiveFTP) thread #15 - Threads|ExchangeTracer - ID-INDIGO5-59921-1365002690852-4-2 >>> (ReceiveFromFTP) pipeline --> split[tokenize(body, \r\n)] <<< Pattern:InOnly, Headers:{CamelFilePath=ids//FTP_ftpTest.txt_20130403102739040.txt, CamelFileName=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLastModified=1365002520000, CamelFileHost=192.168.21.11, breadcrumbId=ID-INDIGO5-59921-1365002690852-4-1, CamelFileAbsolute=false, CamelFileParent=ids, CamelFileNameOnly=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLocalWorkPath=..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt, CamelFileRelativePath=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLength=141, CamelFileAbsolutePath=ids/FTP_ftpTest.txt_20130403102739040.txt}, BodyType:org.apache.camel.component.file.remote.RemoteFile, Body:[Body is file based: RemoteFile[FTP_ftpTest.txt_20130403102739040.txt]]
2013-04-03T10:28:22.024-0500|DEBUG|Thread:Camel (receiveFTP) thread #15 - Threads|org.apache.camel.processor.DefaultErrorHandler - Redelivery enabled: true on error handler: DefaultErrorHandler[Channel[sendTo(Endpoint[file://D:/Temp/ids-test/ftpReceive/?fileName=Received_%24%7BexchangeId%7D_%24%7Bfile%3Aonlyname%7D])]]
2013-04-03T10:28:22.040-0500|DEBUG|Thread:Camel (receiveFTP) thread #15 - Threads|org.apache.camel.processor.MulticastProcessor - Waiting for on-the-fly aggregation to complete aggregating 1 responses for exchangeId: ID-INDIGO5-59921-1365002690852-4-2
2013-04-03T10:28:22.040-0500|INFO |Thread:Camel (receiveFTP) thread #16 - Split|ExchangeTracer - ID-INDIGO5-59921-1365002690852-4-3 >>> (ReceiveFromFTP) from(ftp://192.168.21.11:21/ids/?binary=false&consumer.bridgeErrorHandler=true&delay=1000&delete=true&include=.*%5C.txt&localWorkDirectory=..%2F..%2Fids_temp%2F&maxMessagesPerPoll=100&moveFailed=.failed&passiveMode=true&password=1ds%23%232013&pollStrategy=%23ftpPollStrategy&readLock=rename&throwExceptionOnConnectFailed=true&username=idstest) --> file://D:/Temp/ids-test/ftpReceive/?fileName=Received_%24%7BexchangeId%7D_%24%7Bfile%3Aonlyname%7D <<< Pattern:InOnly, Headers:{CamelFileRelativePath=FTP_ftpTest.txt_20130403102739040.txt, CamelFileHost=192.168.21.11, CamelFileLength=141, CamelFileAbsolute=false, breadcrumbId=ID-INDIGO5-59921-1365002690852-4-1, CamelFileParent=ids, CamelFileLocalWorkPath=..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt, CamelFileName=FTP_ftpTest.txt_20130403102739040.txt, CamelFileNameOnly=FTP_ftpTest.txt_20130403102739040.txt, CamelFileAbsolutePath=ids/FTP_ftpTest.txt_20130403102739040.txt, CamelFilePath=ids//FTP_ftpTest.txt_20130403102739040.txt, CamelFileLastModified=1365002520000}, BodyType:String, Body:-rw-r--r-- 1 ftp ftp 141 Apr 03 10:22 FTP_ftpTest.txt_20130403102739040.txt
2013-04-03T10:28:22.040-0500|DEBUG|Thread:Camel (receiveFTP) thread #16 - Split|org.apache.camel.processor.SendProcessor - >>>> Endpoint[file://D:/Temp/ids-test/ftpReceive/?fileName=Received_%24%7BexchangeId%7D_%24%7Bfile%3Aonlyname%7D] Exchange[null]
2013-04-03T10:28:22.040-0500|DEBUG|Thread:Camel (receiveFTP) thread #16 - Split|org.apache.camel.component.file.FileOperations - Using InputStream to write file: D:\Temp\ids-test\ftpReceive\Received_ID-INDIGO5-59921-1365002690852-4-3_FTP_ftpTest.txt_20130403102739040.txt
2013-04-03T10:28:22.118-0500|DEBUG|Thread:Camel (receiveFTP) thread #16 - Split|org.apache.camel.component.file.GenericFileProducer - Wrote [D:\Temp\ids-test\ftpReceive\Received_ID-INDIGO5-59921-1365002690852-4-3_FTP_ftpTest.txt_20130403102739040.txt] to [Endpoint[file://D:/Temp/ids-test/ftpReceive/?fileName=Received_%24%7BexchangeId%7D_%24%7Bfile%3Aonlyname%7D]]
2013-04-03T10:28:22.118-0500|INFO |Thread:Camel (receiveFTP) thread #16 - Split|ExchangeTracer - ID-INDIGO5-59921-1365002690852-4-3 >>> (ReceiveFromFTP) from(ftp://192.168.21.11:21/ids/?binary=false&consumer.bridgeErrorHandler=true&delay=1000&delete=true&include=.*%5C.txt&localWorkDirectory=..%2F..%2Fids_temp%2F&maxMessagesPerPoll=100&moveFailed=.failed&passiveMode=true&password=1ds%23%232013&pollStrategy=%23ftpPollStrategy&readLock=rename&throwExceptionOnConnectFailed=true&username=idstest) --> file://D:/Temp/ids-test/ftpReceive/?fileName=Received_%24%7BexchangeId%7D_%24%7Bfile%3Aonlyname%7D <<< Pattern:InOnly, Headers:{CamelFileNameProduced=D:\Temp\ids-test\ftpReceive\Received_ID-INDIGO5-59921-1365002690852-4-3_FTP_ftpTest.txt_20130403102739040.txt, CamelFileAbsolutePath=ids/FTP_ftpTest.txt_20130403102739040.txt, CamelFileNameOnly=FTP_ftpTest.txt_20130403102739040.txt, CamelFileParent=ids, CamelFileHost=192.168.21.11, CamelFileRelativePath=FTP_ftpTest.txt_20130403102739040.txt, CamelFileAbsolute=false, CamelFileLocalWorkPath=..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt, CamelFileLastModified=1365002520000, breadcrumbId=ID-INDIGO5-59921-1365002690852-4-1, CamelFilePath=ids//FTP_ftpTest.txt_20130403102739040.txt, CamelFileLength=141, CamelFileName=FTP_ftpTest.txt_20130403102739040.txt}, BodyType:String, Body:-rw-r--r-- 1 ftp ftp 141 Apr 03 10:22 FTP_ftpTest.txt_20130403102739040.txt
2013-04-03T10:28:22.180-0500|INFO |Thread:pool-15-thread-1|com.it.ids.gui.delegates.admin.AccountManagementDelegate - Successfully loaded customers to user-interface table.
2013-04-03T10:28:22.321-0500|DEBUG|Thread:Camel (receiveFTP) thread #17 - Splitter-AggregateTask|org.apache.camel.processor.MulticastProcessor - Done aggregating 1 exchanges on the fly.
2013-04-03T10:28:22.321-0500|DEBUG|Thread:Camel (receiveFTP) thread #17 - Splitter-AggregateTask|org.apache.camel.processor.MulticastProcessor - Signaling we are done aggregating on the fly for exchangeId: ID-INDIGO5-59921-1365002690852-4-2
2013-04-03T10:28:22.321-0500|DEBUG|Thread:Camel (receiveFTP) thread #15 - Threads|org.apache.camel.processor.MulticastProcessor - Done parallel processing 1 exchanges
2013-04-03T10:28:22.321-0500|INFO |Thread:Camel (receiveFTP) thread #15 - Threads|ExchangeTracer - ID-INDIGO5-59921-1365002690852-4-2 >>> (ReceiveFromFTP) pipeline --> split[tokenize(body, \r\n)] <<< Pattern:InOnly, Headers:{CamelFilePath=ids//FTP_ftpTest.txt_20130403102739040.txt, CamelFileName=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLastModified=1365002520000, CamelFileHost=192.168.21.11, breadcrumbId=ID-INDIGO5-59921-1365002690852-4-1, CamelFileAbsolute=false, CamelFileParent=ids, CamelFileNameOnly=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLocalWorkPath=..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt, CamelFileRelativePath=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLength=141, CamelFileAbsolutePath=ids/FTP_ftpTest.txt_20130403102739040.txt}, BodyType:org.apache.camel.component.file.remote.RemoteFile, Body:[Body is file based: RemoteFile[FTP_ftpTest.txt_20130403102739040.txt]]
2013-04-03T10:28:22.477-0500|INFO |Thread:Camel (receiveFTP) thread #15 - Threads|ExchangeTracer - ID-INDIGO5-59921-1365002690852-4-2 >>> (ReceiveFromFTP) pipeline --> split[tokenize(body, \r\n)] <<< Pattern:InOnly, Headers:{CamelFilePath=ids//FTP_ftpTest.txt_20130403102739040.txt, CamelFileName=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLastModified=1365002520000, CamelFileHost=192.168.21.11, breadcrumbId=ID-INDIGO5-59921-1365002690852-4-1, CamelFileAbsolute=false, CamelFileParent=ids, CamelFileNameOnly=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLocalWorkPath=..\..\ids_temp\FTP_ftpTest.txt_20130403102739040.txt, CamelFileRelativePath=FTP_ftpTest.txt_20130403102739040.txt, CamelFileLength=141, CamelFileAbsolutePath=ids/FTP_ftpTest.txt_20130403102739040.txt}, BodyType:org.apache.camel.component.file.remote.RemoteFile, Body:[Body is file based: RemoteFile[FTP_ftpTest.txt_20130403102739040.txt]]
2013-04-03T10:28:22.477-0500|DEBUG|Thread:Camel (receiveFTP) thread #13 - ftp://192.168.21.11:21/ids/|org.apache.camel.component.file.GenericFileOnCompletion - Done processing file: RemoteFile[FTP_ftpTest.txt_20130403102739040.txt] using exchange: Exchange[FTP_ftpTest.txt_20130403102739040.txt]
On receiving FTP file, the BodyType is *BodyType:org.apache.camel.component.file.remote.RemoteFile*
After starting Split - *BodyType:String*.
This is all I can read from the log.
> Camel Split doesn't processes the payload of the file, received via FTP
> -----------------------------------------------------------------------
>
> Key: CAMEL-6231
> URL: https://issues.apache.org/jira/browse/CAMEL-6231
> Project: Camel
> Issue Type: Bug
> Components: camel-ftp
> Affects Versions: 2.10.4
> Reporter: Igor Ivaniuk
> Assignee: Willem Jiang
>
> I'm having troubles trying to create a route that splits files received from FTP.
> Here is the configuration (in Spring DSL):
> {noformat}
> <camelContext id="receiveFTP" trace="true" xmlns="http://camel.apache.org/schema/spring" >
> <threadPoolProfile id="receiveFTP-splitter-profile"
> defaultProfile="false" poolSize="20"
> maxPoolSize="30"/>
> <!-- Endpoints -->
> <endpoint id="FileOutput" uri="file:D:/Temp/camel-test/ftpReceive/?fileName=Received_${exchangeId}_${file:onlyname}" />
> <endpoint id="FTPSource" uri="ftp://192.168.21.11:21/folder/?pollStrategy=#ftpPollStrategy&throwExceptionOnConnectFailed=true&binary=false&passiveMode=true&readLock=rename&delete=true&moveFailed=.failed&include=.*\.txt&delay=1000&localWorkDirectory=../../camel_temp/&username=username&password=password&maxMessagesPerPoll=100&consumer.bridgeErrorHandler=true" />
> <!-- Routes -->
> <route id="ReceiveFromFTP">
> <from ref="FTPSource" />
> <threads poolSize="1" maxPoolSize="1">
> <split streaming="true" parallelProcessing="true" executorServiceRef="receiveFTP-splitter-profile">
> <tokenize token="\r\n"/>
> <to ref="FileOutput"/>
> </split>
> </threads>
> </route>
> </camelContext>
> {noformat}
> The FTP location contains a file with several lines, I'm trying to split it, and in the output location I have one file with the following content:
> {noformat}-rw-r--r-- 1 ftp ftp 141 Apr 02 08:04 FTP_ftpTest.txt_20130402081001301.txt{noformat}
> Looks like the Split component doesn't take the payload of the received file. Even more, adding <convertBodyTo type="java.lang.String"/> before splitting resolves the problem. But I assume this is not expected behavior.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira