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.
