camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Igor Ivaniuk (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (CAMEL-6231) Camel Split doesn't processes the payload of the file, received via FTP
Date Wed, 03 Apr 2013 14:45:16 GMT

    [ 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&amp;throwExceptionOnConnectFailed=true&amp;binary=false&amp;passiveMode=true&amp;readLock=rename&amp;delete=true&amp;moveFailed=.failed&amp;include=.*\.txt&amp;delay=1000&amp;localWorkDirectory=../../camel_temp/&amp;username=username&amp;password=password&amp;maxMessagesPerPoll=100&amp;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

Mime
View raw message