[activemq-user] Question about ConcurrentModificationException on ActiveMQ.Adviso ry.TempDestinations.temp-queue.TemporaryQueue

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

[activemq-user] Question about ConcurrentModificationException on ActiveMQ.Adviso ry.TempDestinations.temp-queue.TemporaryQueue

gklyuzner
What is the implication of this warning?

...
2005-06-22 11:38:12,908 [ocalport=61616]] DEBUG
ientQueueBoundedMessageManager - Adding consumer: CONSUMER_INFO: id = 29
ConsumerInfo{ browser = false, destination =
TemporaryQueue-{TD{ID:ny-cap-33-2097-1119454689326-16:0}TD}ID:ny-cap-33-2097
-1119454689326-32:0, consumerIdentifier =
'ID:ny-cap-33-2097-1119454689326-16:0.3.5' , clientId =
'ID:ny-cap-33-2097-1119454689326-16:0' , sessionId = '3' , consumerName = ''
, selector = '' , startTime = 1119454692716, started = true, consumerNo = 5,
noLocal = false, prefetchNumber = 1000, consumerKey =
'[ID:ny-cap-33-2097-1119454689326-16:0:]'  }

2005-06-22 11:38:12,939 [ocalport=61616]] WARN  BrokerClientImpl
- caught exception consuming packet: CONSUMER_INFO: id = 349 ConsumerInfo{
browser = false, destination =
ActiveMQ.Advisory.TempDestinations.temp-queue.TemporaryQueue-{TD{ID:ny-cap-3
3-2097-1119454689326-16:0}TD}ID:ny-cap-33-2097-1119454689326-34:0,
consumerIdentifier = 'ID:ny-cap-33-1977-1119453699438-16:0.28.60' , clientId
= 'ID:ny-cap-33-1977-1119453699438-16:0' , sessionId = '28' , consumerName =
'' , selector = '' , startTime = 1119454692748, started = true, consumerNo =
60, noLocal = false, prefetchNumber = 1000, consumerKey =
'[ID:ny-cap-33-1977-1119453699438-16:0:]'  }
java.util.ConcurrentModificationException
        at java.util.HashMap$HashIterator.nextEntry(HashMap.java:782)
        at java.util.HashMap$KeyIterator.next(HashMap.java:818)
        at
org.activemq.broker.impl.AdvisorySupport.addAdvisory(AdvisorySupport.java:88
)
        at
org.activemq.broker.impl.DefaultBroker.addMessageConsumer(DefaultBroker.java
:251)
        at
org.activemq.broker.impl.BrokerContainerImpl.registerMessageConsumer(BrokerC
ontainerImpl.java:355)
        at
org.activemq.broker.impl.BrokerConnectorImpl.registerMessageConsumer(BrokerC
onnectorImpl.java:170)
        at
org.activemq.broker.impl.BrokerClientImpl.consumeConsumerInfo(BrokerClientIm
pl.java:479)
        at
org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:331)
        at
org.activemq.transport.TransportChannelSupport.doConsumePacket(TransportChan
nelSupport.java:374)
        at
org.activemq.transport.TransportChannelSupport.doConsumePacket(TransportChan
nelSupport.java:368)
        at
org.activemq.transport.tcp.TcpTransportChannel.run(TcpTransportChannel.java:
311)
        at java.lang.Thread.run(Thread.java:534)


----------------------------------------------------------------------------
----------------------------------------------------------------------------
-------------------------
The information contained in this email is confidential and may also contain
privileged information. Sender does not waive confidentiality or legal
privilege. If you are not the intended recipient please notify the sender
immediately; you should not retain this message or disclose its content to
anyone.
Internet communications are not secure or error free and the sender does not
accept any liability for the content of the email. Although emails are
routinely screened for viruses, the sender does not accept responsibility
for any damage caused. Replies to this email may be monitored.
For more information about the Collins Stewart Tullett group of companies
please visit the following web site: www.cstplc.com
----------------------------------------------------------------------------
----------------------------------------------------------------------------
--------------------------

Reply | Threaded
Open this post in threaded view
|

Re: [activemq-user] Question about ConcurrentModificationException on ActiveMQ.Adviso ry.TempDestinations.temp-queue.TemporaryQueue

jstrachan
I think I've resolved this issue - though without a test case its a  
little hard to know for sure. This fix should appear in the  
forthcoming 3.1-M3 release.


On 22 Jun 2005, at 12:18, [hidden email] wrote:

> What is the implication of this warning?
>
> ...
> 2005-06-22 11:38:12,908 [ocalport=61616]] DEBUG
> ientQueueBoundedMessageManager - Adding consumer: CONSUMER_INFO: id  
> = 29
> ConsumerInfo{ browser = false, destination =
> TemporaryQueue-{TD{ID:ny-cap-33-2097-1119454689326-16:0}TD}ID:ny-
> cap-33-2097
> -1119454689326-32:0, consumerIdentifier =
> 'ID:ny-cap-33-2097-1119454689326-16:0.3.5' , clientId =
> 'ID:ny-cap-33-2097-1119454689326-16:0' , sessionId = '3' ,  
> consumerName = ''
> , selector = '' , startTime = 1119454692716, started = true,  
> consumerNo = 5,
> noLocal = false, prefetchNumber = 1000, consumerKey =
> '[ID:ny-cap-33-2097-1119454689326-16:0:]'  }
>
> 2005-06-22 11:38:12,939 [ocalport=61616]] WARN  BrokerClientImpl
> - caught exception consuming packet: CONSUMER_INFO: id = 349  
> ConsumerInfo{
> browser = false, destination =
> ActiveMQ.Advisory.TempDestinations.temp-queue.TemporaryQueue-{TD
> {ID:ny-cap-3
> 3-2097-1119454689326-16:0}TD}ID:ny-cap-33-2097-1119454689326-34:0,
> consumerIdentifier = 'ID:ny-cap-33-1977-1119453699438-16:0.28.60' ,  
> clientId
> = 'ID:ny-cap-33-1977-1119453699438-16:0' , sessionId = '28' ,  
> consumerName =
> '' , selector = '' , startTime = 1119454692748, started = true,  
> consumerNo =
> 60, noLocal = false, prefetchNumber = 1000, consumerKey =
> '[ID:ny-cap-33-1977-1119453699438-16:0:]'  }
> java.util.ConcurrentModificationException
>     at java.util.HashMap$HashIterator.nextEntry(HashMap.java:782)
>     at java.util.HashMap$KeyIterator.next(HashMap.java:818)
>     at
> org.activemq.broker.impl.AdvisorySupport.addAdvisory
> (AdvisorySupport.java:88
> )
>     at
> org.activemq.broker.impl.DefaultBroker.addMessageConsumer
> (DefaultBroker.java
> :251)
>     at
> org.activemq.broker.impl.BrokerContainerImpl.registerMessageConsumer
> (BrokerC
> ontainerImpl.java:355)
>     at
> org.activemq.broker.impl.BrokerConnectorImpl.registerMessageConsumer
> (BrokerC
> onnectorImpl.java:170)
>     at
> org.activemq.broker.impl.BrokerClientImpl.consumeConsumerInfo
> (BrokerClientIm
> pl.java:479)
>     at
> org.activemq.broker.impl.BrokerClientImpl.consume
> (BrokerClientImpl.java:331)
>     at
> org.activemq.transport.TransportChannelSupport.doConsumePacket
> (TransportChan
> nelSupport.java:374)
>     at
> org.activemq.transport.TransportChannelSupport.doConsumePacket
> (TransportChan
> nelSupport.java:368)
>     at
> org.activemq.transport.tcp.TcpTransportChannel.run
> (TcpTransportChannel.java:
> 311)
>     at java.lang.Thread.run(Thread.java:534)
>
>
> ----------------------------------------------------------------------
> ------
> ----------------------------------------------------------------------
> ------
> -------------------------
> The information contained in this email is confidential and may  
> also contain
> privileged information. Sender does not waive confidentiality or legal
> privilege. If you are not the intended recipient please notify the  
> sender
> immediately; you should not retain this message or disclose its  
> content to
> anyone.
> Internet communications are not secure or error free and the sender  
> does not
> accept any liability for the content of the email. Although emails are
> routinely screened for viruses, the sender does not accept  
> responsibility
> for any damage caused. Replies to this email may be monitored.
> For more information about the Collins Stewart Tullett group of  
> companies
> please visit the following web site: www.cstplc.com
> ----------------------------------------------------------------------
> ------
> ----------------------------------------------------------------------
> ------
> --------------------------
>
>


James
-------
http://radio.weblogs.com/0112098/