The property is set on the *incoming* exchange, not the one you send.
Could you paste a bigger snippet of code as I have no way to know which variable
is what ....
On Wed, Feb 27, 2008 at 3:27 PM, sachin2008 <[EMAIL PROTECTED]> wrote:
>
> 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.
>
>
--
Cheers,
Guillaume Nodet
------------------------
Blog: http://gnodet.blogspot.com/
