activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hackingbear <hackingb...@gmail.com>
Subject Re: Network broker and filter predicate
Date Sat, 14 Nov 2009 20:20:45 GMT

OK, I got it to use v5 OpenWire, but the exact problem occurs in v5 as well.

What can I do? (Looks like I can just create my own BooleanPredicate class
that extends DataStructure either because I don't have a data struct type ID
to use.)

 WARN DemandForwardingBridge Caught an exception processing local command
[@BrokerService] 2009-11-14 12:13:21,800
java.lang.ClassCastException: org.apache.activemq.filter.UnaryExpression$2
cannot be cast to org.apache.activemq.command.DataStructure
	at
org.apache.activemq.openwire.v5.ConsumerInfoMarshaller.tightMarshal1(ConsumerInfoMarshaller.java:131)
	at
org.apache.activemq.openwire.OpenWireFormat.tightMarshalNestedObject1(OpenWireFormat.java:403)
	at
org.apache.activemq.openwire.v5.BaseDataStreamMarshaller.tightMarshalNestedObject1(BaseDataStreamMarshaller.java:131)
	at
org.apache.activemq.openwire.v5.MessageMarshaller.tightMarshal1(MessageMarshaller.java:139)
	at
org.apache.activemq.openwire.v5.ActiveMQMessageMarshaller.tightMarshal1(ActiveMQMessageMarshaller.java:76)
	at
org.apache.activemq.openwire.OpenWireFormat.marshal(OpenWireFormat.java:231)
	at
org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:166)
	at
org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:237)
	at
org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:83)
	at
org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:104)
	at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
	at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
	at
org.apache.activemq.network.DemandForwardingBridgeSupport.serviceLocalCommand(DemandForwardingBridgeSupport.java:691)
	at
org.apache.activemq.network.DemandForwardingBridgeSupport$1.onCommand(DemandForwardingBridgeSupport.java:156)
	at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:109)
	at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
	at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:114)
	at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
	at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
	at
org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1190)
	at
org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:779)
	at
org.apache.activemq.broker.TransportConnection.iterate(TransportConnection.java:815)
	at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
	at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
	at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
	at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
	at java.lang.Thread.run(Thread.java:619)
 INFO DemandForwardingBridge Network connection between vm://tsgw#12 and
tcp://localhost/127.0.0.1:61616 shutdown due to a local error:
java.lang.ClassCastException: org.apache.activemq.filter.UnaryExpression$2
cannot be cast to org.apache.activemq.command.DataStructure [@BrokerService]
2009-11-14 12:13:21,801


Gary Tully wrote:
> 
> Just a though, with the latest 5.3.0 release, the wireformat version
> is 5. Enable debug logging to validate the wireformat negotiation
> between the brokers to see what is the problem. Possibly there is some
> mix up in the classpath or something.
> 

-- 
View this message in context: http://old.nabble.com/Network-broker-and-filter-predicate-tp26259578p26353542.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message