Can someone tell me why only one message of the six splitted is processed by
the recipient (see my previous post where the log has been added) ? Is it an
issue with the Recipient or the combination of splitter + recipient + spring
?
KR,
Charles
cmoulliard wrote:
>
> I hope so ...
>
> Here is the trace which is not really conclusive because we only see :
>
> setHeader(//price/@stock)
>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: ->
> interceptor(Delegate(Pipeline[DeadLetterChannel[Delegate(TraceInterceptor[Splitter[xpath{//priceXPath:
> //price} -> [SetHeader[stock, xpath{//price/@stockXPath: //price/@stock}],
> SetHeader[queueName,
> simple{jms:topic:STOCK.${in.header.stock}jms:topic:STOCK.${in.header.stock}}]]]]),
> RecipientList[log:org.apache.camel.DeadLetterChannel?level=error]],
> DeadLetterChannel[Delegate(TraceInterceptor[RecipientList[header{queueNameheader(queueName)}]]),
> RecipientList[log:org.apache.camel.DeadLetterChannel?level=error]]])) ,
> Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{CamelFileLastModified=Tue Oct 21 14:06:50 CEST 2008,
> CamelFileAbsolutePath=d:\temp\quotes\quotes.xml, CamelFileLength=512,
> CamelFileName=quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> CamelFilePath=d:\temp\quotes\quotes.xml, CamelFileParent=d:\temp\quotes,
> org.apache.camel.file.name=quotes.xml} , Body:<?xml version="1.0"
> encoding="ISO-8859-1"?>
> <quotes>
> <price stock="MSFT" bid="2.008" offer="2.012" movement="up"/>
> <price stock="SUNW" bid="1.034" offer="1.035" movement="down"/>
> <price stock="IBMW" bid="2.008" offer="2.012" movement="up"/>
> <price stock="DEXI" bid="1.456" offer="1.035" movement="up"/>
> <price stock="INGB" bid="1.078" offer="1.035" movement="down"/>
> <price stock="KBCB" bid="4.234" offer="1.035" movement="down"/>
> <price stock="COLR" bid="6.123" offer="1.035" movement="up"/>
> </quotes>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> splitter(//price) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{CamelFileLastModified=Tue Oct 21 14:06:50 CEST 2008,
> CamelFileAbsolutePath=d:\temp\quotes\quotes.xml, CamelFileLength=512,
> CamelFileName=quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> CamelFilePath=d:\temp\quotes\quotes.xml, CamelFileParent=d:\temp\quotes,
> org.apache.camel.file.name=quotes.xml} , Body:<?xml version="1.0"
> encoding="ISO-8859-1"?>
> <quotes>
> <price stock="MSFT" bid="2.008" offer="2.012" movement="up"/>
> <price stock="SUNW" bid="1.034" offer="1.035" movement="down"/>
> <price stock="IBMW" bid="2.008" offer="2.012" movement="up"/>
> <price stock="DEXI" bid="1.456" offer="1.035" movement="up"/>
> <price stock="INGB" bid="1.078" offer="1.035" movement="down"/>
> <price stock="KBCB" bid="4.234" offer="1.035" movement="down"/>
> <price stock="COLR" bid="6.123" offer="1.035" movement="up"/>
> </quotes>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(//price/@stock) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> CamelFileName=quotes.xml, CamelFileLength=512,
> CamelFilePath=d:\temp\quotes\quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> org.apache.camel.splitCounter=0, CamelFileParent=d:\temp\quotes,
> org.apache.camel.file.name=quotes.xml} , Body:<price bid="2.008"
> movement="up" offer="2.012" stock="MSFT"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(jms:topic:STOCK.${in.header.stock}) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> [EMAIL PROTECTED],
> CamelFileLength=512, CamelFileName=quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> CamelFilePath=d:\temp\quotes\quotes.xml, CamelFileParent=d:\temp\quotes,
> org.apache.camel.splitCounter=0, org.apache.camel.file.name=quotes.xml} ,
> Body:<price bid="2.008" movement="up" offer="2.012" stock="MSFT"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(//price/@stock) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> CamelFileName=quotes.xml, CamelFileLength=512,
> CamelFilePath=d:\temp\quotes\quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> org.apache.camel.splitCounter=1, CamelFileParent=d:\temp\quotes,
> org.apache.camel.file.name=quotes.xml} , Body:<price bid="1.034"
> movement="down" offer="1.035" stock="SUNW"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(jms:topic:STOCK.${in.header.stock}) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> [EMAIL PROTECTED],
> CamelFileLength=512, CamelFileName=quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> CamelFilePath=d:\temp\quotes\quotes.xml, CamelFileParent=d:\temp\quotes,
> org.apache.camel.splitCounter=1, org.apache.camel.file.name=quotes.xml} ,
> Body:<price bid="1.034" movement="down" offer="1.035" stock="SUNW"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(//price/@stock) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> CamelFileName=quotes.xml, CamelFileLength=512,
> CamelFilePath=d:\temp\quotes\quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> org.apache.camel.splitCounter=2, CamelFileParent=d:\temp\quotes,
> org.apache.camel.file.name=quotes.xml} , Body:<price bid="2.008"
> movement="up" offer="2.012" stock="IBMW"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(jms:topic:STOCK.${in.header.stock}) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> [EMAIL PROTECTED],
> CamelFileLength=512, CamelFileName=quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> CamelFilePath=d:\temp\quotes\quotes.xml, CamelFileParent=d:\temp\quotes,
> org.apache.camel.splitCounter=2, org.apache.camel.file.name=quotes.xml} ,
> Body:<price bid="2.008" movement="up" offer="2.012" stock="IBMW"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(//price/@stock) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> CamelFileName=quotes.xml, CamelFileLength=512,
> CamelFilePath=d:\temp\quotes\quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> org.apache.camel.splitCounter=3, CamelFileParent=d:\temp\quotes,
> org.apache.camel.file.name=quotes.xml} , Body:<price bid="1.456"
> movement="up" offer="1.035" stock="DEXI"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(jms:topic:STOCK.${in.header.stock}) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> [EMAIL PROTECTED],
> CamelFileLength=512, CamelFileName=quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> CamelFilePath=d:\temp\quotes\quotes.xml, CamelFileParent=d:\temp\quotes,
> org.apache.camel.splitCounter=3, org.apache.camel.file.name=quotes.xml} ,
> Body:<price bid="1.456" movement="up" offer="1.035" stock="DEXI"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(//price/@stock) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> CamelFileName=quotes.xml, CamelFileLength=512,
> CamelFilePath=d:\temp\quotes\quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> org.apache.camel.splitCounter=4, CamelFileParent=d:\temp\quotes,
> org.apache.camel.file.name=quotes.xml} , Body:<price bid="1.078"
> movement="down" offer="1.035" stock="INGB"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(jms:topic:STOCK.${in.header.stock}) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> [EMAIL PROTECTED],
> CamelFileLength=512, CamelFileName=quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> CamelFilePath=d:\temp\quotes\quotes.xml, CamelFileParent=d:\temp\quotes,
> org.apache.camel.splitCounter=4, org.apache.camel.file.name=quotes.xml} ,
> Body:<price bid="1.078" movement="down" offer="1.035" stock="INGB"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(//price/@stock) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> CamelFileName=quotes.xml, CamelFileLength=512,
> CamelFilePath=d:\temp\quotes\quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> org.apache.camel.splitCounter=5, CamelFileParent=d:\temp\quotes,
> org.apache.camel.file.name=quotes.xml} , Body:<price bid="4.234"
> movement="down" offer="1.035" stock="KBCB"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(jms:topic:STOCK.${in.header.stock}) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> [EMAIL PROTECTED],
> CamelFileLength=512, CamelFileName=quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> CamelFilePath=d:\temp\quotes\quotes.xml, CamelFileParent=d:\temp\quotes,
> org.apache.camel.splitCounter=5, org.apache.camel.file.name=quotes.xml} ,
> Body:<price bid="4.234" movement="down" offer="1.035" stock="KBCB"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(//price/@stock) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> CamelFileName=quotes.xml, CamelFileLength=512,
> CamelFilePath=d:\temp\quotes\quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> org.apache.camel.splitCounter=6, CamelFileParent=d:\temp\quotes,
> org.apache.camel.file.name=quotes.xml} , Body:<price bid="6.123"
> movement="up" offer="1.035" stock="COLR"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> setHeader(jms:topic:STOCK.${in.header.stock}) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008, CamelFileAbsolutePath=d:\temp\quotes\quotes.xml,
> [EMAIL PROTECTED],
> CamelFileLength=512, CamelFileName=quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> CamelFilePath=d:\temp\quotes\quotes.xml, CamelFileParent=d:\temp\quotes,
> org.apache.camel.splitCounter=6, org.apache.camel.file.name=quotes.xml} ,
> Body:<price bid="6.123" movement="up" offer="1.035" stock="COLR"/>
> 21-oct.-2008 14:32:16 org.apache.camel.processor.Logger process
> GRAVE: -> recipientList(queueName) , Pattern:InOnly ,
> Properties:{org.apache.camel.file.lock=sun.nio.ch.FileLockImpl[0:9223372036854775807
> exclusive valid],
> org.apache.camel.file.lock.name=d:\temp\quotes\quotes.xml.camelLock} ,
> Headers:{org.apache.camel.splitSize=7, CamelFileLastModified=Tue Oct 21
> 14:06:50 CEST 2008,
> [EMAIL PROTECTED],
> CamelFileAbsolutePath=d:\temp\quotes\quotes.xml, CamelFileName=quotes.xml,
> CamelFileLength=512, CamelFilePath=d:\temp\quotes\quotes.xml,
> CamelFileCanonicalPath=D:\Temp\quotes\quotes.xml,
> org.apache.camel.splitCounter=6, CamelFileParent=d:\temp\quotes,
> queueName=jms:topic:STOCK.COLR, org.apache.camel.file.name=quotes.xml} ,
> Body:<price bid="6.123" movement="up" offer="1.035" stock="COLR"/>
> 21-oct.-2008 14:32:16 org.apache.activemq.broker.BrokerService start
> INFO: Using Persistence Adapter: MemoryPersistenceAdapter
> 21-oct.-2008 14:32:16 org.apache.activemq.broker.BrokerService getBroker
> INFO: ActiveMQ 5.1.0 JMS Message Broker (localhost) is starting
> 21-oct.-2008 14:32:16 org.apache.activemq.broker.BrokerService getBroker
> INFO: For help or more information please see: http://activemq.apache.org/
> 21-oct.-2008 14:32:16 org.apache.activemq.broker.jmx.ManagementContext$1
> run
> INFO: JMX consoles can connect to
> service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
> 21-oct.-2008 14:32:17 org.apache.activemq.broker.BrokerService start
> INFO: ActiveMQ JMS Message Broker (localhost,
> ID:dell-charles-1742-1224592336890-0:0) started
> 21-oct.-2008 14:32:17 org.apache.activemq.broker.TransportConnector start
> INFO: Connector vm://localhost Started
>
>
> James.Strachan wrote:
>>
>> And you are sure the headers are being set to create different stocks
>> right? (Use the tracer to see them?)
>>
>>
>> 2008/10/21 cmoulliard <[EMAIL PROTECTED]>:
>>>
>>> Idem. Only one topic is created (STOCK.BEAS).
>>>
>>>
>>> James.Strachan wrote:
>>>>
>>>> 2008/10/21 cmoulliard <[EMAIL PROTECTED]>:
>>>>>
>>>>> James,
>>>>>
>>>>> What do you mean by "It looks like the issue is the carriage return at
>>>>> the
>>>>> end of the queue
>>>>> name; if you remove that it should be fine." ? I don't understand
>>>>>
>>>>> Remark : there is one error in my route definition
>>>>>
>>>>> <simple>"jms:topic:STOCK.${in.header.stock}
>>>>>
>>>>> -->
>>>>>
>>>>> <simple>jms:topic:STOCK.${in.header.stock}</simple>
>>>>
>>>> Yes thats it. Whats the stack trace if you remove that whitespace at
>>>> the end of the URI?
>>>>
>>>> --
>>>> James
>>>> -------
>>>> http://macstrac.blogspot.com/
>>>>
>>>> Open Source Integration
>>>> http://fusesource.com/
>>>>
>>>>
>>>
>>>
>>> -----
>>> Enterprise Architect
>>>
>>> Xpectis
>>> 12, route d'Esch
>>> L-1470 Luxembourg
>>>
>>> Phone +352 25 10 70 470
>>> Mobile +352 621 45 36 22
>>>
>>> e-mail : [EMAIL PROTECTED]
>>> web site : www.xpectis.com www.xpectis.com
>>> My Blog : http://cmoulliard.blogspot.com/
>>> http://cmoulliard.blogspot.com/
>>> --
>>> View this message in context:
>>> http://www.nabble.com/How-to-define-dynamically-the-jms-uri---tp20067678s22882p20088925.html
>>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>>
>>>
>>
>>
>>
>> --
>> James
>> -------
>> http://macstrac.blogspot.com/
>>
>> Open Source Integration
>> http://fusesource.com/
>>
>>
>
>
-----
Enterprise Architect
Xpectis
12, route d'Esch
L-1470 Luxembourg
Phone +352 25 10 70 470
Mobile +352 621 45 36 22
e-mail : [EMAIL PROTECTED]
web site : www.xpectis.com www.xpectis.com
My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/
--
View this message in context:
http://www.nabble.com/How-to-define-dynamically-the-jms-uri---tp20067678s22882p20105027.html
Sent from the Camel - Users mailing list archive at Nabble.com.
