Camel
  1. Camel
  2. CAMEL-6231

Camel Split doesn't processes the payload of the file, received via FTP

    Details

    • Type: Bug Bug
    • Status: Resolved
    • Priority: Major Major
    • Resolution: Invalid
    • Affects Version/s: 2.10.4
    • Fix Version/s: None
    • Component/s: camel-ftp
    • Labels:
      None
    • Estimated Complexity:
      Unknown

      Description

      I'm having troubles trying to create a route that splits files received from FTP.

      Here is the configuration (in Spring DSL):

      <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>
      

      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:

      -rw-r--r-- 1 ftp ftp            141 Apr 02 08:04 FTP_ftpTest.txt_20130402081001301.txt

      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.

        Activity

        Hide
        Willem Jiang added a comment -

        Hi,

        I just checked the code, and did some basic tests. It looks like Camel should be able handle the payload of file out of box. I'm not sure if there is something wrong with the Charset setting. Can you check the camel error log for more information?

        Willem

        Show
        Willem Jiang added a comment - Hi, I just checked the code, and did some basic tests. It looks like Camel should be able handle the payload of file out of box. I'm not sure if there is something wrong with the Charset setting. Can you check the camel error log for more information? Willem
        Hide
        Igor Ivaniuk added a comment - - edited

        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.

        Show
        Igor Ivaniuk added a comment - - edited 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.
        Hide
        Claus Ibsen added a comment -

        Removed the <threads>

        Show
        Claus Ibsen added a comment - Removed the <threads>
        Hide
        Claus Ibsen added a comment -

        You should not use both threads and splitter with parallel.

        Show
        Claus Ibsen added a comment - You should not use both threads and splitter with parallel.

          People

          • Assignee:
            Willem Jiang
            Reporter:
            Igor Ivaniuk
          • Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development