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/
