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/
