I am not able to trace that one
I am getting the same exception continuously. Whether there is any way to
set that global variable anywhere else.
gnodet wrote:
>
> Did you add a trace to check if the property
> "org.apache.servicemix.correlationId"
> was not null ? Else I would try the solution I first proposed which
> is to set these
> properties in the component which sends these 3 exchanges and only make
> sure
> that these properties are conveyed by the 3 lightweight components.
>
> On Wed, Feb 27, 2008 at 3:43 PM, sachin2008 <[EMAIL PROTECTED]> wrote:
>>
>> I am attching the code for the three components i have used and the
>> xbean of
>> the eip component.
>>
>> Can you please look into it.
>>
>>
>>
>>
>> gnodet wrote:
>> >
>> > 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/
>> >
>> >
>> http://www.nabble.com/file/p15714689/ThreadSampleEOS.java
>> ThreadSampleEOS.java
>> http://www.nabble.com/file/p15714689/ThreadSampleEWOW.java
>> ThreadSampleEWOW.java
>> http://www.nabble.com/file/p15714689/ThreadSampleMI.java
>> ThreadSampleMI.java
>> http://www.nabble.com/file/p15714689/xbean.xml xbean.xml
>> --
>> View this message in context:
>> http://www.nabble.com/Reg%3AAggregator-Pattern-tp15582806s12049p15714689.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-tp15582806s12049p15714993.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.
