Details
Description
Sometimes when creating a temporary topic I get:
Exception in thread "tcp:///127.0.0.1:39442" java.lang.ClassCastException: org.apache.activemq.command.ActiveMQTempTopic
at org.apache.activemq.openwire.v1.DestinationInfoMarshaller.unmarshal(DestinationInfoMarshaller.java:67)
at org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:214)
at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:181)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:135)
at java.lang.Thread.run(Thread.java:595)
This only seems to happen if I try to create a lot of temp topics in a lot of different threads at the same time.
Attachments
Issue Links
- is duplicated by
-
AMQ-646 Receiver hangs after receiving about 1000 messages
- Closed