activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Steve Angelovich <SAngelov...@lgc.com>
Subject occasional ConcurrentModificationException when creating a queue consumer
Date Tue, 07 Jun 2011 14:45:34 GMT
All,

Can anybody give me some ideas about why I get the ConcurrentModificationExcpetion below occasionally.
 We are running with version 5.5.

The code that generates this exception is;

LOG.fine("Create response queue") ;
_session2 = _connection.createSession(false, Session.AUTO_ACKNOWLEDGE) ;
_tempDest = _session2.createTemporaryQueue();
_responseConsumer = _session2.createConsumer(_tempDest);

The client is setting up an additional session, creating a temporary queue and then adding
a consumer for use in a request/reply scenario.  The last line results in the exception below
occasionally.

Thanks for any insights.
Steve



WARNING: !0: javax.jms.JMSException: java.util.ConcurrentModificationException
WARNING: !0: 	at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49)
WARNING: !0: 	at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1295)
WARNING: !0: 	at org.apache.activemq.ActiveMQSession.syncSendPacket(ActiveMQSession.java:1874)
WARNING: !0: 	at org.apache.activemq.ActiveMQMessageConsumer.(ActiveMQMessageConsumer.java:254)
WARNING: !0: 	at org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:1116)
WARNING: !0: 	at org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:1060)
WARNING: !0: 	at org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:973)
WARNING: !0: 	at org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:946)
WARNING: !0: 	at com.lgc.prowess.sitemanager.client.SiteManagerCommander.createResponseQueue(SiteManagerCommander.java:87)
WARNING: !0: 	at com.lgc.prowess.sitemanager.client.SiteManagerCommander.getNetDir(SiteManagerCommander.java:253)
WARNING: !0: 	at com.lgc.prowess.sitemanager.client.NetDirManager.(NetDirManager.java:26)
WARNING: !0: 	at com.lgc.prowess.sitemanager.client.SiteManagerClient.getNetDirManager(SiteManagerClient.java:325)
WARNING: !0: 	at com.lgc.prowess.sitemanager.netdir.NetDir.(NetDir.java:90)
WARNING: !0: 	at com.lgc.prowess.sitemanager.netdir.NetDir.get(NetDir.java:60)
WARNING: !0: 	at com.lgc.prowess.seisdata.PromaxDatasetFactory.open(PromaxDatasetFactory.java:52)
WARNING: !0: 	at com.lgc.prowess.seisdata.PromaxDatasetFactory.open(PromaxDatasetFactory.java:67)
WARNING: !0: 	at com.lgc.prowess.seisdata.SeismicDatasetFactory.open(SeismicDatasetFactory.java:118)
WARNING: !0: 	at com.lgc.prowess.seisdata.SeisUtil.openDataset(SeisUtil.java:161)
WARNING: !0: 	at com.lgc.prowess.tool.input.SmartInputTool.openDataset(SmartInputTool.java:857)
WARNING: !0: 	at com.lgc.prowess.tool.input.SmartInputTool.initCapsules(SmartInputTool.java:224)
WARNING: !0: 	at com.lgc.prowess.exec.ExecThread.(ExecThread.java:648)
WARNING: !0: 	at com.lgc.prowess.exec.ExecWorkerBase.initExecThread(ExecWorkerBase.java:339)
WARNING: !0: 	at com.lgc.prowess.exec.ExecWorkerBase.doInitPhase(ExecWorkerBase.java:125)
WARNING: !0: 	at com.lgc.prowess.exec.ExecMPIWorker.doInitPhase(ExecMPIWorker.java:231)
WARNING: !0: 	at com.lgc.prowess.exec.ExecMPIWorker.doWork(ExecMPIWorker.java:112)
WARNING: !0: 	at com.lgc.prowess.exec.ExecMPI.main(ExecMPI.java:37)
WARNING: !0: Caused by: java.util.ConcurrentModificationException
WARNING: !0: 	at java.util.HashMap$HashIterator.nextEntry(HashMap.java:793)
WARNING: !0: 	at java.util.HashMap$EntryIterator.next(HashMap.java:834)
WARNING: !0: 	at java.util.HashMap$EntryIterator.next(HashMap.java:832)
WARNING: !0: 	at java.util.HashMap.putAllForCreate(HashMap.java:435)
WARNING: !0: 	at java.util.HashMap.(HashMap.java:225)
WARNING: !0: 	at org.slf4j.helpers.BasicMDCAdapter.getCopyOfContextMap(BasicMDCAdapter.java:130)
WARNING: !0: 	at org.slf4j.MDC.getCopyOfContextMap(MDC.java:176)
WARNING: !0: 	at org.apache.activemq.util.MDCHelper.getCopyOfContextMap(MDCHelper.java:30)
WARNING: !0: 	at org.apache.activemq.thread.PooledTaskRunner.(PooledTaskRunner.java:42)
WARNING: !0: 	at org.apache.activemq.thread.TaskRunnerFactory.createTaskRunner(TaskRunnerFactory.java:80)
WARNING: !0: 	at org.apache.activemq.broker.region.Topic.(Topic.java:89)
WARNING: !0: 	at org.apache.activemq.broker.region.DestinationFactoryImpl.createDestination(DestinationFactoryImpl.java:99)
WARNING: !0: 	at org.apache.activemq.broker.region.AbstractRegion.createDestination(AbstractRegion.java:473)
WARNING: !0: 	at org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:123)
WARNING: !0: 	at org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:301)
WARNING: !0: 	at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
WARNING: !0: 	at org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:145)
WARNING: !0: 	at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
WARNING: !0: 	at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
WARNING: !0: 	at org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:151)
WARNING: !0: 	at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:502)
WARNING: !0: 	at org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:515)
WARNING: !0: 	at org.apache.activemq.advisory.AdvisoryBroker.fireConsumerAdvisory(AdvisoryBroker.java:464)
WARNING: !0: 	at org.apache.activemq.advisory.AdvisoryBroker.fireConsumerAdvisory(AdvisoryBroker.java:450)
WARNING: !0: 	at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:85)
WARNING: !0: 	at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89)
WARNING: !0: 	at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89)
WARNING: !0: 	at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:95)
WARNING: !0: 	at org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:546)
WARNING: !0: 	at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:349)
WARNING: !0: 	at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
WARNING: !0: 	at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
WARNING: !0: 	at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
WARNING: !0: 	at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
WARNING: !0: 	at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:227)
WARNING: !0: 	at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
WARNING: !0: 	at org.apache.activemq.transport.nio.NIOTransport.serviceRead(NIOTransport.java:129)
WARNING: !0: 	at org.apache.activemq.transport.nio.NIOTransport.access$000(NIOTransport.java:44)
WARNING: !0: 	at org.apache.activemq.transport.nio.NIOTransport$1.onSelect(NIOTransport.java:68)
WARNING: !0: 	at org.apache.activemq.transport.nio.SelectorSelection.onSelect(SelectorSelection.java:94)
WARNING: !0: 	at org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker.java:119)
WARNING: !0: 	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
WARNING: !0: 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
WARNING: !0: 	at java.lang.Thread.run(Thread.java:619)

----------------------------------------------------------------------
This e-mail, including any attached files, may contain confidential and privileged information
for the sole use of the intended recipient.  Any review, use, distribution, or disclosure
by others is strictly prohibited.  If you are not the intended recipient (or authorized to
receive information for the intended recipient), please contact the sender by reply e-mail
and delete all copies of this message.

Mime
View raw message