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.
