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.
