activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tim Bain <tb...@alumni.duke.edu>
Subject Re: ClassCastException: Consumer Advisory Topic
Date Thu, 07 Dec 2017 01:19:14 GMT
Are you by any chance using a different version of the ActiveMQ client
library than the version the broker is running?

Maybe share your code that creates the consumer, and maybe someone can spot
something?

Tim

On Dec 4, 2017 7:24 AM, "MarcelHillmann" <marcel.hillmann1@allianz.de>
wrote:

> Hi,
>
> I try to subscribe the connection advisory topic, and I seen an
> ClassCastException.
>
> Is this a known issue?
> How can I solve it?
>
> Thanks
> Marcel
>
> java.io.IOException: org.apache.activemq.command.BrokerId cannot be cast
> to
> org.apache.activemq.command.ConsumerId
>         at
> org.apache.activemq.util.IOExceptionSupport.create(
> IOExceptionSupport.java:40)
>         at
> org.apache.activemq.transport.nio.NIOTransport.serviceRead(
> NIOTransport.java:168)
>         at
> org.apache.activemq.transport.nio.NIOTransport$1.onSelect(
> NIOTransport.java:80)
>         at
> org.apache.activemq.transport.nio.SelectorSelection.
> onSelect(SelectorSelection.java:98)
>         at
> org.apache.activemq.transport.nio.SelectorWorker$1.run(
> SelectorWorker.java:118)
>         at
> java.util.concurrent.ThreadPoolExecutor.runWorker(
> ThreadPoolExecutor.java:1142)
>         at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:617)
>         at java.lang.Thread.run(Thread.java:745)
> Caused by: java.lang.ClassCastException:
> org.apache.activemq.command.BrokerId cannot be cast to
> org.apache.activemq.command.ConsumerId
>         at
> org.apache.activemq.openwire.v12.MessageMarshaller.tightUnmarshal(
> MessageMarshaller.java:75)
>         at
> org.apache.activemq.openwire.v12.ActiveMQMessageMarshaller.tightUnmarshal(
> ActiveMQMessageMarshaller.java:66)
>         at
> org.apache.activemq.openwire.OpenWireFormat.tightUnmarshalNestedObject(
> OpenWireFormat.java:456)
>         at
> org.apache.activemq.openwire.v12.BaseDataStreamMarshaller.
> tightUnmarsalNestedObject(BaseDataStreamMarshaller.java:125)
>         at
> org.apache.activemq.openwire.v12.MessageDispatchMarshaller.tightUnmarshal(
> MessageDispatchMarshaller.java:71)
>         at
> org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(
> OpenWireFormat.java:365)
>         at
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(
> OpenWireFormat.java:278)
>         at
> org.apache.activemq.transport.nio.NIOTransport.serviceRead(
> NIOTransport.java:154)
>         ... 6 more
>
>
>
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-
> f2341805.html
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message