By setting correlation id as below i am getting an exception like:
Could not retrieve correlation id for incoming exchange.
gnodet wrote:
>
> I must have misunderstood how your code works.
> I thought a given component was creating 3 messages and was sending them.
> If this is not the case, you may be able to use the global
> correlationId which is
> available on the exchange:
> exhcange.getProperty("org.apache.servicemix.correlationId")
> This property should have the same value for all 3 exchanges and should be
> different for each group.
> in.setProperty(AbstractSplitter.SPLITTER_CORRID,
>
> exchange.getProperty("org.apache.servicemix.correlationId") );
>
> Another way would be to set the property when you *split* the messages
> instead
> of when you *aggregate* them. That's what I was referring to, and I
> thought about
> using the original exchange id as the correlation id for the 3
> generated exchanges.
>
> On Wed, Feb 27, 2008 at 2:57 PM, sachin2008 <[EMAIL PROTECTED]> wrote:
>>
>> As i said earlier i have hardcoded the coded the correlation id as
>>
>> in.setProperty(AbstractSplitter.SPLITTER_CORRID,exchange.getExchangeId()
>> );
>> in the three components but by tracing the log i found that exchange id
>> for
>> the three components A,B and C as mentioned in the use case before are
>> different so i can't aggregate the messages coming from the three
>> components.
>> So there is anyother way to set the correlation id.
>>
>>
>>
>> gnodet wrote:
>> >
>> > I don't think these exceptions are related.
>> > Maybe you end up in a timeout ?
>> >
>> > On Wed, Feb 27, 2008 at 11:59 AM, sachin2008 <[EMAIL PROTECTED]>
>> wrote:
>> >>
>> >> I am not able to aggregate the message when i have hardcoded the
>> >> correlation
>> >> id as
>> >>
>> >>
>> >>
>> in.setProperty(AbstractSplitter.SPLITTER_CORRID,exchange.getExchangeId()
>> >> );
>> >>
>> >> But i am getting an exception from JMSprovider as :
>> >>
>> >> java.io.EOFException
>> >> at java.io.DataInputStream.readInt(DataInputStream.java:358)
>> >> at
>> >>
>> >>
>> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:156)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)
>> >>
>> >> at java.lang.Thread.run(Thread.java:595)
>> >> 16:18:52,695 | WARN | ActiveMQ Scheduler | ActiveMQConnection
>> |
>> >> he.activemq.ActiveMQConnection 1523 | Async exception with no
>> exception
>> >> listener: org.apache.activemq.transport.InactivityIOException:
>> Channel
>> >> was
>> >> inactive for too long.
>> >> org.apache.activemq.transport.InactivityIOException: Channel was
>> >> inactive
>> >> for too long.
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.InactivityMonitor.readCheck(InactivityMonitor.java:101)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.InactivityMonitor.access$000(InactivityMonitor.java:35)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.InactivityMonitor$1.run(InactivityMonitor.java:51)
>> >> at
>> >>
>> >>
>> edu.emory.mathcs.backport.java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:442)
>> >> at
>> >>
>> >>
>> edu.emory.mathcs.backport.java.util.concurrent.FutureTask.runAndReset(FutureTask.java:198)
>> >> at
>> >>
>> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:102)
>> >> at
>> >>
>> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:189)
>> >> at
>> >>
>> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:213)
>> >> at
>> >>
>> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:665)
>> >> at
>> >>
>> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:690)
>> >>
>> >> at java.lang.Thread.run(Thread.java:595)
>> >> 16:18:53,273 | WARN | AcitveMQ Connection Worker:
>> >> tcp://localhost/127.0.0.1:61616 | ctiveMQManagedConnection |
>> >> q.ra.ActiveMQManagedConnection 407 | Connection failed:
>> >> javax.jms.JMSException: java.io.EOFException
>> >> 16:18:53,945 | WARN | AcitveMQ Connection Worker:
>> >> tcp://localhost/127.0.0.1:61616 | oConnectionEventListener |
>> >> eronimoConnectionEventListener 87 | connectionErrorOccurred called
>> >> with
>> >> null
>> >> javax.jms.JMSException: java.io.EOFException
>> >> at
>> >>
>> >>
>> org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:46)
>> >> at
>> >>
>> >>
>> org.apache.activemq.ActiveMQConnection.onAsyncException(ActiveMQConnection.java:1513)
>> >> at
>> >>
>> >>
>> org.apache.activemq.ActiveMQConnection.onException(ActiveMQConnection.java:1529)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:96)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.ResponseCorrelator.onException(ResponseCorrelator.java:114)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:96)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:96)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.WireFormatNegotiator.onException(WireFormatNegotiator.java:147)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.InactivityMonitor.onException(InactivityMonitor.java:150)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.TransportSupport.onException(TransportSupport.java:97)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:150)
>> >>
>> >> at java.lang.Thread.run(Thread.java:595)
>> >> Caused by: java.io.EOFException
>> >> at java.io.DataInputStream.readInt(DataInputStream.java:358)
>> >> at
>> >>
>> >>
>> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:156)
>> >> at
>> >>
>> >>
>> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)
>> >> ... 1 more
>> >>
>> >> Can u please tell me how to resolve this issue.
>> >>
>> >>
>> >>
>> >> gnodet wrote:
>> >> >
>> >> > It works, but for each group of messages, you need to generate a
>> >> > unique id for the
>> >> > SPLITTER_CORRID property. The easiest way would be to use the id
>> >> > of the incoming exchange (which will always be unique).
>> >> >
>> >> > On Wed, Feb 27, 2008 at 11:15 AM, sachin2008
>> <[EMAIL PROTECTED]>
>> >> wrote:
>> >> >>
>> >> >> Thanks for your reply..
>> >> >>
>> >> >> For aggregator how should i set correlationid,index and count.
>> >> >>
>> >> >> In my usecase i already said that:
>> >> >> I have hardcoded like this......
>> >> >> Component A:
>> >> >> in.setProperty(AbstractSplitter.SPLITTER_COUNT, new Integer(3));
>> >> >> in.setProperty(AbstractSplitter.SPLITTER_CORRID, "id");
>> >> >> in.setProperty(AbstractSplitter.SPLITTER_INDEX, new Integer(0));
>> >> >> Component B:
>> >> >> in.setProperty(AbstractSplitter.SPLITTER_COUNT, new Integer(3));
>> >> >> in.setProperty(AbstractSplitter.SPLITTER_CORRID, "id");
>> >> >> in.setProperty(AbstractSplitter.SPLITTER_INDEX, new Integer(1));
>> >> >> Component C:
>> >> >> in.setProperty(AbstractSplitter.SPLITTER_COUNT, new Integer(3));
>> >> >> in.setProperty(AbstractSplitter.SPLITTER_CORRID, "id");
>> >> >> in.setProperty(AbstractSplitter.SPLITTER_INDEX, new Integer(2));
>> >> >>
>> >> >> Can you please help me in configuring the aggregator
>> properities...
>> >> >>
>> >> >>
>> >> >>
>> >> >>
>> >> >> gnodet wrote:
>> >> >> >
>> >> >> > The aggregator uses three properties: the correlationId (which
>> >> >> > identifies messages related together), the index and the
>> count.
>> >> >> > Each group of messages must have a different correlationId,
>> while
>> >> all
>> >> >> > the messages in a given group must have the same
>> correlationId.
>> >> Then,
>> >> >> > inside a group, no two messages can have the same index.
>> >> >> > You need to make sure these rules are followed, or you'll have
>> to
>> >> hack
>> >> >> > your own aggregation strategy.
>> >> >> >
>> >> >> > By checking the log at DEBUG level (or remote debugging the
>> >> >> > aggregator), you should be able to see what message are
>> received,
>> >> >> > hence the cause of the error.
>> >> >> >
>> >> >> > On Wed, Feb 27, 2008 at 10:23 AM, sachin2008
>> >> <[EMAIL PROTECTED]>
>> >> >> wrote:
>> >> >> >>
>> >> >> >> Presently i am able to aggregate the messages through
>> >> aggregator.
>> >> >> >>
>> >> >> >> But there is a problem.....
>> >> >> >>
>> >> >> >> First of all i will explain my usecase:
>> >> >> >>
>> >> >> >> JMSConsumer------>static
>> >> >> >>
>> >> receipientlist----->lw-container------>aggregator------>JMSProvider
>> >> >> >>
>> >> >> >> I am sending a request from JMSconsumer to static receipient
>> >> list.
>> >> >> from
>> >> >> >> static receipientlist i am sending three inonly messages to
>> >> >> >> lw-container.In
>> >> >> >> lw-container i have used three components namely A,B and C.
>> From
>> >> >> >> component
>> >> >> >> A, i am sending an inonly message to aggregator by setting
>> index
>> >> as
>> >> >> >> 0,count
>> >> >> >> as 3 and corelationid as id and From Component B, i am
>> sending
>> >> an
>> >> >> >> inonly
>> >> >> >> message to aggregator by setting index as 1,count as 3 and
>> >> >> corelationid
>> >> >> >> as
>> >> >> >> id and From Component C, i am sending an inonly message to
>> >> >> aggregator by
>> >> >> >> setting index as 2,count as 3 and corelationid as id.I am
>> able
>> >> to
>> >> >> get
>> >> >> >> the
>> >> >> >> aggregated message from the aggregator to JMSProvider.
>> >> >> >>
>> >> >> >> Problems:
>> >> >> >> I am getting aggregated message in JMSProvider successfully
>> only
>> >> for
>> >> >> the
>> >> >> >> first request .
>> >> >> >>
>> >> >> >> But if i have given another request it is giving some
>> exception
>> >> >> like:
>> >> >> >>
>> >> >> >>
>> >> >> >> ERROR - EIPComponent - Error processing
>> >> exchange
>> >> >> >> InOnly[
>> >> >> >> id: ID:pc007869-2244-1204099875217-12:313
>> >> >> >> status: Active
>> >> >> >> role: provider
>> >> >> >> endpoint: aggregate
>> >> >> >> in: <?xml version="1.0" encoding="UTF-8"?><EOS><PAYL_HDR>
>> >> >> <DUNS_NBR>
>> >> >> >> 313955098
>> >> >> >> </DUNS_NBR></PAYL_HDR></EOS>
>> >> >> >> ]
>> >> >> >> java.lang.IllegalStateException: Message with index 0 has
>> >> already
>> >> >> been
>> >> >> >> received
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.patterns.SplitAggregator.addMessage(SplitAg
>> >> >> >> gregator.java:213)
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.support.AbstractAggregator.process(Abstract
>> >> >> >> Aggregator.java:159)
>> >> >> >>
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLi
>> >> >> >> feCycle.java:489)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(Async
>> >> >> >> BaseLifeCycle.java:441)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLife
>> >> >> >> Cycle.java:46)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBoun
>> >> >> >> d(DeliveryChannelImpl.java:593)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlo
>> >> >> >> w.java:174)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.j
>> >> >> >> ava:176)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.jav
>> >> >> >> a:134)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.runTask(ThreadPoolExecutor.java:665)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.run(ThreadPoolExecutor.java:690)
>> >> >> >> at java.lang.Thread.run(Thread.java:595)
>> >> >> >> ERROR - EIPComponent - Error processing
>> >> exchange
>> >> >> >> InOnly[
>> >> >> >> id: ID:pc007869-2244-1204099875217-13:286
>> >> >> >> status: Active
>> >> >> >> role: provider
>> >> >> >> endpoint: aggregate
>> >> >> >> in: <?xml version="1.0"
>> encoding="UTF-8"?><EWOW><FAM_TREE_LINK>
>> >> >> <ASSN>
>> >> >> >> <ASSN_T
>> >> >> >> YPE_CD>1019</ASSN_TYPE_CD></ASSN></FAM_TREE_LINK></EWOW>
>> >> >> >> ]
>> >> >> >> java.lang.IllegalStateException: Message with index 1 has
>> >> already
>> >> >> been
>> >> >> >> received
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.patterns.SplitAggregator.addMessage(SplitAg
>> >> >> >> gregator.java:213)
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.support.AbstractAggregator.process(Abstract
>> >> >> >> Aggregator.java:159)
>> >> >> >>
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLi
>> >> >> >> feCycle.java:489)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(Async
>> >> >> >> BaseLifeCycle.java:441)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLife
>> >> >> >> Cycle.java:46)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBoun
>> >> >> >> d(DeliveryChannelImpl.java:593)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlo
>> >> >> >> w.java:174)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.j
>> >> >> >> ava:176)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.jav
>> >> >> >> a:134)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.runTask(ThreadPoolExecutor.java:665)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.run(ThreadPoolExecutor.java:690)
>> >> >> >> at java.lang.Thread.run(Thread.java:595)
>> >> >> >> ERROR - EIPComponent - Error processing
>> >> exchange
>> >> >> >> InOnly[
>> >> >> >> id: ID:pc007869-2244-1204099875217-14:293
>> >> >> >> status: Active
>> >> >> >> role: provider
>> >> >> >> endpoint: aggregate
>> >> >> >> in: <?xml version="1.0" encoding="UTF-8"?><MI><PAYL_HDR>
>> >> <DUNS_NBR>
>> >> >> >> 313955098<
>> >> >> >> /DUNS_NBR></PAYL_HDR></MI>
>> >> >> >> ]
>> >> >> >> java.lang.IllegalStateException: Message with index 2 has
>> >> already
>> >> >> been
>> >> >> >> received
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.patterns.SplitAggregator.addMessage(SplitAg
>> >> >> >> gregator.java:213)
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.support.AbstractAggregator.process(Abstract
>> >> >> >> Aggregator.java:159)
>> >> >> >>
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLi
>> >> >> >> feCycle.java:489)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(Async
>> >> >> >> BaseLifeCycle.java:441)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLife
>> >> >> >> Cycle.java:46)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBoun
>> >> >> >> d(DeliveryChannelImpl.java:593)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlo
>> >> >> >> w.java:174)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.j
>> >> >> >> ava:176)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.jav
>> >> >> >> a:134)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.runTask(ThreadPoolExecutor.java:665)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.run(ThreadPoolExecutor.java:690)
>> >> >> >> at java.lang.Thread.run(Thread.java:595)
>> >> >> >> ERROR - EIPComponent - Error processing
>> >> exchange
>> >> >> >> InOnly[
>> >> >> >> id: ID:pc007869-2244-1204099875217-12:315
>> >> >> >> status: Active
>> >> >> >> role: provider
>> >> >> >> endpoint: aggregate
>> >> >> >> in: <?xml version="1.0" encoding="UTF-8"?><EOS><PAYL_HDR>
>> >> >> <DUNS_NBR>
>> >> >> >> 313955098
>> >> >> >> </DUNS_NBR></PAYL_HDR></EOS>
>> >> >> >> ]
>> >> >> >> java.lang.IllegalStateException: Message with index 0 has
>> >> already
>> >> >> been
>> >> >> >> received
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.patterns.SplitAggregator.addMessage(SplitAg
>> >> >> >> gregator.java:213)
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.support.AbstractAggregator.process(Abstract
>> >> >> >> Aggregator.java:159)
>> >> >> >>
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLi
>> >> >> >> feCycle.java:489)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(Async
>> >> >> >> BaseLifeCycle.java:441)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLife
>> >> >> >> Cycle.java:46)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBoun
>> >> >> >> d(DeliveryChannelImpl.java:593)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlo
>> >> >> >> w.java:174)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.j
>> >> >> >> ava:176)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.jav
>> >> >> >> a:134)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.runTask(ThreadPoolExecutor.java:665)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.run(ThreadPoolExecutor.java:690)
>> >> >> >> at java.lang.Thread.run(Thread.java:595)
>> >> >> >> ERROR - EIPComponent - Error processing
>> >> exchange
>> >> >> >> InOnly[
>> >> >> >> id: ID:pc007869-2244-1204099875217-12:317
>> >> >> >> status: Active
>> >> >> >> role: provider
>> >> >> >> endpoint: aggregate
>> >> >> >> in: <?xml version="1.0" encoding="UTF-8"?><EOS><PAYL_HDR>
>> >> >> <DUNS_NBR>
>> >> >> >> 313955098
>> >> >> >> </DUNS_NBR></PAYL_HDR></EOS>
>> >> >> >> ]
>> >> >> >> java.lang.IllegalStateException: Message with index 0 has
>> >> already
>> >> >> been
>> >> >> >> received
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.patterns.SplitAggregator.addMessage(SplitAg
>> >> >> >> gregator.java:213)
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.support.AbstractAggregator.process(Abstract
>> >> >> >> Aggregator.java:159)
>> >> >> >>
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLi
>> >> >> >> feCycle.java:489)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(Async
>> >> >> >> BaseLifeCycle.java:441)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLife
>> >> >> >> Cycle.java:46)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBoun
>> >> >> >> d(DeliveryChannelImpl.java:593)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlo
>> >> >> >> w.java:174)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.j
>> >> >> >> ava:176)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.jav
>> >> >> >> a:134)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.runTask(ThreadPoolExecutor.java:665)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.run(ThreadPoolExecutor.java:690)
>> >> >> >> at java.lang.Thread.run(Thread.java:595)
>> >> >> >> ERROR - EIPComponent - Error processing
>> >> exchange
>> >> >> >> InOnly[
>> >> >> >> id: ID:pc007869-2244-1204099875217-12:319
>> >> >> >> status: Active
>> >> >> >> role: provider
>> >> >> >> endpoint: aggregate
>> >> >> >> in: <?xml version="1.0" encoding="UTF-8"?><EOS><PAYL_HDR>
>> >> >> <DUNS_NBR>
>> >> >> >> 313955098
>> >> >> >> </DUNS_NBR></PAYL_HDR></EOS>
>> >> >> >> ]
>> >> >> >> java.lang.IllegalStateException: Message with index 0 has
>> >> already
>> >> >> been
>> >> >> >> received
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.patterns.SplitAggregator.addMessage(SplitAg
>> >> >> >> gregator.java:213)
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.support.AbstractAggregator.process(Abstract
>> >> >> >> Aggregator.java:159)
>> >> >> >>
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLi
>> >> >> >> feCycle.java:489)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(Async
>> >> >> >> BaseLifeCycle.java:441)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLife
>> >> >> >> Cycle.java:46)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBoun
>> >> >> >> d(DeliveryChannelImpl.java:593)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlo
>> >> >> >> w.java:174)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.j
>> >> >> >> ava:176)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.jav
>> >> >> >> a:134)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.runTask(ThreadPoolExecutor.java:665)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.run(ThreadPoolExecutor.java:690)
>> >> >> >> at java.lang.Thread.run(Thread.java:595)
>> >> >> >> ERROR - EIPComponent - Error processing
>> >> exchange
>> >> >> >> InOnly[
>> >> >> >> id: ID:pc007869-2244-1204099875217-13:288
>> >> >> >> status: Active
>> >> >> >> role: provider
>> >> >> >> endpoint: aggregate
>> >> >> >> in: <?xml version="1.0"
>> encoding="UTF-8"?><EWOW><FAM_TREE_LINK>
>> >> >> <ASSN>
>> >> >> >> <ASSN_T
>> >> >> >> YPE_CD>1019</ASSN_TYPE_CD></ASSN></FAM_TREE_LINK></EWOW>
>> >> >> >> ]
>> >> >> >> java.lang.IllegalStateException: Message with index 1 has
>> >> already
>> >> >> been
>> >> >> >> received
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.patterns.SplitAggregator.addMessage(SplitAg
>> >> >> >> gregator.java:213)
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.support.AbstractAggregator.process(Abstract
>> >> >> >> Aggregator.java:159)
>> >> >> >>
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLi
>> >> >> >> feCycle.java:489)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(Async
>> >> >> >> BaseLifeCycle.java:441)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLife
>> >> >> >> Cycle.java:46)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBoun
>> >> >> >> d(DeliveryChannelImpl.java:593)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlo
>> >> >> >> w.java:174)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.j
>> >> >> >> ava:176)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.jav
>> >> >> >> a:134)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.runTask(ThreadPoolExecutor.java:665)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.run(ThreadPoolExecutor.java:690)
>> >> >> >> at java.lang.Thread.run(Thread.java:595)
>> >> >> >> ERROR - EIPComponent - Error processing
>> >> exchange
>> >> >> >> InOnly[
>> >> >> >> id: ID:pc007869-2244-1204099875217-14:295
>> >> >> >> status: Active
>> >> >> >> role: provider
>> >> >> >> endpoint: aggregate
>> >> >> >> in: <?xml version="1.0" encoding="UTF-8"?><MI><PAYL_HDR>
>> >> <DUNS_NBR>
>> >> >> >> 313955098<
>> >> >> >> /DUNS_NBR></PAYL_HDR></MI>
>> >> >> >> ]
>> >> >> >> java.lang.IllegalStateException: Message with index 2 has
>> >> already
>> >> >> been
>> >> >> >> received
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.patterns.SplitAggregator.addMessage(SplitAg
>> >> >> >> gregator.java:213)
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.eip.support.AbstractAggregator.process(Abstract
>> >> >> >> Aggregator.java:159)
>> >> >> >>
>> >> >> >>
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLi
>> >> >> >> feCycle.java:489)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(Async
>> >> >> >> BaseLifeCycle.java:441)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLife
>> >> >> >> Cycle.java:46)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBoun
>> >> >> >> d(DeliveryChannelImpl.java:593)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlo
>> >> >> >> w.java:174)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.j
>> >> >> >> ava:176)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.jav
>> >> >> >> a:134)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.runTask(ThreadPoolExecutor.java:665)
>> >> >> >> at
>> >> >> >>
>> >> >>
>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
>> >> >> >> ker.run(ThreadPoolExecutor.java:690)
>> >> >> >> at java.lang.Thread.run(Thread.java:595)
>> >> >> >>
>> >> >> >>
>> >> >> >> Can anyone please help me to resolve this issue...
>> >> >> >>
>> >> >> >> Thanks in advanced.
>> >> >> >>
>> >> >> >>
>> >> >> >>
>> >> >> >>
>> >> >> >> gnodet wrote:
>> >> >> >> >
>> >> >> >> > The jsr181 component can be configured with a given
>> instance
>> >> of
>> >> >> the
>> >> >> >> > class that will be used to process all the incoming
>> exchanges.
>> >> >> You
>> >> >> >> > just need to make sure your code is designed to be used
>> that
>> >> way:
>> >> >> a
>> >> >> >> > single instance will receive all calls concurrently, as in
>> the
>> >> >> >> > servlets world. The servicemix-bean behaves the same way.
>> >> >> >> >
>> >> >> >> > Another way would be to implement your own aggregation
>> >> strategy
>> >> >> using
>> >> >> >> > servicemix-eip or camel.
>> >> >> >> > Servicemix-eip already provides some aggregation and can
>> be
>> >> >> extended
>> >> >> >> > (but does not use any jaxb marshaling, so it depends if
>> you
>> >> need
>> >> >> it or
>> >> >> >> > not). Camel is really flexible and powerful and it may be
>> >> worth
>> >> >> to
>> >> >> >> > take a look at it.
>> >> >> >> >
>> >> >> >> > On Wed, Feb 20, 2008 at 6:37 AM, sachin2008
>> >> <[EMAIL PROTECTED]>
>> >> >> >> wrote:
>> >> >> >> >>
>> >> >> >> >> Hi,
>> >> >> >> >>
>> >> >> >> >> I am having a scenario:
>> >> >> >> >>
>> >> >> >> >> HTTP(BC)------->
>> >> >> JSR----------->Aggregator---------------->HTTP(BC)
>> >> >> >> >>
>> >> >> >> >> My requirement is:
>> >> >> >> >>
>> >> >> >> >> In JSR, we need incorporate the multi threading logic
>> for
>> >> >> getting
>> >> >> >> the
>> >> >> >> >> data
>> >> >> >> >> from different data sources and by using the aggregator
>> >> pattern
>> >> >> we
>> >> >> >> need
>> >> >> >> >> to
>> >> >> >> >> aggregate the xml data coming from different datasources
>> and
>> >> >> send
>> >> >> >> the
>> >> >> >> >> response back to the HTTP(BC).
>> >> >> >> >>
>> >> >> >> >> Can anyone please tell me how to use the aggregator
>> pattern
>> >> in
>> >> >> this
>> >> >> >> >> regard.
>> >> >> >> >>
>> >> >> >> >> --
>> >> >> >> >> View this message in context:
>> >> >> >> >>
>> >> >> >>
>> >> >>
>> >>
>> http://www.nabble.com/Reg%3AAggregator-Pattern-tp15582806s12049p15582806.html
>> >> >> >> >> Sent from the ServiceMix - User mailing list archive at
>> >> >> Nabble.com.
>> >> >> >> >>
>> >> >> >> >>
>> >> >> >> >
>> >> >> >> >
>> >> >> >> >
>> >> >> >> > --
>> >> >> >> > Cheers,
>> >> >> >> > Guillaume Nodet
>> >> >> >> > ------------------------
>> >> >> >> > Blog: http://gnodet.blogspot.com/
>> >> >> >> >
>> >> >> >> >
>> >> >> >>
>> >> >> >> --
>> >> >> >> View this message in context:
>> >> >> >>
>> >> >>
>> >>
>> http://www.nabble.com/Reg%3AAggregator-Pattern-tp15582806s12049p15709304.html
>> >> >> >>
>> >> >> >>
>> >> >> >> Sent from the ServiceMix - User mailing list archive at
>> >> Nabble.com.
>> >> >> >>
>> >> >> >>
>> >> >> >
>> >> >> >
>> >> >> >
>> >> >> > --
>> >> >> > Cheers,
>> >> >> > Guillaume Nodet
>> >> >> > ------------------------
>> >> >> > Blog: http://gnodet.blogspot.com/
>> >> >> >
>> >> >> >
>> >> >>
>> >> >> --
>> >> >> View this message in context:
>> >> >>
>> >>
>> http://www.nabble.com/Reg%3AAggregator-Pattern-tp15582806s12049p15710141.html
>> >> >>
>> >> >>
>> >> >> Sent from the ServiceMix - User mailing list archive at
>> Nabble.com.
>> >> >>
>> >> >>
>> >> >
>> >> >
>> >> >
>> >> > --
>> >> > Cheers,
>> >> > Guillaume Nodet
>> >> > ------------------------
>> >> > Blog: http://gnodet.blogspot.com/
>> >> >
>> >> >
>> >>
>> >> --
>> >> View this message in context:
>> >>
>> http://www.nabble.com/Reg%3AAggregator-Pattern-tp15582806s12049p15710910.html
>> >>
>> >>
>> >> Sent from the ServiceMix - User mailing list archive at Nabble.com.
>> >>
>> >>
>> >
>> >
>> >
>> > --
>> > Cheers,
>> > Guillaume Nodet
>> > ------------------------
>> > Blog: http://gnodet.blogspot.com/
>> >
>> >
>>
>> --
>> View this message in context:
>> http://www.nabble.com/Reg%3AAggregator-Pattern-tp15582806s12049p15713713.html
>>
>>
>> Sent from the ServiceMix - User mailing list archive at Nabble.com.
>>
>>
>
>
>
> --
> Cheers,
> Guillaume Nodet
> ------------------------
> Blog: http://gnodet.blogspot.com/
>
>
--
View this message in context:
http://www.nabble.com/Reg%3AAggregator-Pattern-tp15582806s12049p15714156.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.
