activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christian Posta <christian.po...@gmail.com>
Subject Re: ActiveMQ 5.8-SNAPSHOT problems connecting to older versions
Date Fri, 30 Nov 2012 20:30:46 GMT
I just tried with the latest (today's code) and 5.5.1 and 5.6.0. They seem
to make the duplex connection just fine (the older versions are creating
the network bridge).

In general, however, I would say the broker's aren't guaranteed to network
with each other between versions. The clients + openwire are good about
being backward compatible, but the brokers don't always play nicely when
networking different versions.

If you post more details (broker configs?) I can try to reproduce and tell
you exactly why it's not working to see if there's a work around.




On Fri, Nov 30, 2012 at 10:18 AM, RonK <ron.koerner@wincor-nixdorf.com>wrote:

> Hi all,
>
> on trying the latest ActiveMQ 5.8-SNAPSHOT broker, I get these errors, when
> other brokers (older versions, but at least 5.6) try to make a duplex
> connection.
>
> 2012-11-30 17:16:21,443 ERROR emq.broker.TransportConnection - Failed to
> create responder end of duplex network bridge
> VMware-564da62f85a02cb5-77679e89d883f760@ID:vmbox-41253-1354292010393-0:1
> [ActiveMQ NIO Worker 2]
> java.lang.IllegalArgumentException: Invalid connect parameters:
> {network=true, async=false}
>         at
>
> org.apache.activemq.transport.vm.VMTransportFactory.doCompositeConnect(VMTransportFactory.java:157)
> ~[activemq-broker-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> org.apache.activemq.transport.vm.VMTransportFactory.doConnect(VMTransportFactory.java:54)
> ~[activemq-broker-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:64)
> ~[activemq-client-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> org.apache.activemq.broker.TransportConnection.processBrokerInfo(TransportConnection.java:1243)
> [activemq-broker-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
> org.apache.activemq.command.BrokerInfo.visit(BrokerInfo.java:126)
> [activemq-client-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
> [activemq-broker-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:150)
> [activemq-broker-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
> [activemq-client-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
> [activemq-client-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:278)
> [activemq-client-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> [activemq-client-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> org.apache.activemq.transport.nio.NIOTransport.serviceRead(NIOTransport.java:138)
> [activemq-client-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> org.apache.activemq.transport.nio.NIOTransport$1.onSelect(NIOTransport.java:69)
> [activemq-client-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> org.apache.activemq.transport.nio.SelectorSelection.onSelect(SelectorSelection.java:94)
> [activemq-client-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker.java:119)
> [activemq-client-5.8-SNAPSHOT.jar:5.8-SNAPSHOT]
>         at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> [na:1.6.0_20]
>         at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> [na:1.6.0_20]
>         at java.lang.Thread.run(Thread.java:619) [na:1.6.0_20]
>
> The other broker has this network connector:
>
>             <networkConnector brokerName="${brokername}" name="${serial}"
> uri="static://(tcp://${addr}:${port})" duplex="true" userName="${user}"
> password="${password}" networkTTL="5" dynamicOnly="true"
> decreaseNetworkConsumerPriority="false" prefetchSize="1000">
>
> plus some dynamically included destinations.
>
> Regards,
> Ron
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-5-8-SNAPSHOT-problems-connecting-to-older-versions-tp4660039.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>



-- 
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta

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