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.
