Uploaded image for project: 'JBoss A-MQ'
  1. JBoss A-MQ
  2. ENTMQ-686

Fabric Discovery protocol is not backward compatible for mq clients

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • JBoss A-MQ 6.1
    • JBoss A-MQ 6.0
    • Documentation
    • None

    Description

      The fabric discovery protocol is not backward compatible in 6.1.The mq-client.jar shipped with this JBoss A-MQ 6.0 in the extras directory demonstrates this issue when trying to use the fabric discovery protocol to connect to brokers deployed in 6.1.| jasons-mbp:extras jsherman$ java -jar mq-client.jar consumer --count 100 --sleep 1000 --user admin --password admin --brokerUrl discovery:fabric:replicated|

      Picked up JAVA_TOOL_OPTIONS: -Djava.awt.headless=true
      Using destination: queue://TEST, on broker: discovery:fabric:replicated
      [org.fusesource.mq.fabric.FabricDiscoveryAgent] : Using local ZKClient
      [org.fusesource.fabric.zookeeper.internal.AbstractZKClient] : Starting StateChangeDispatcher
      [org.apache.zookeeper.ZooKeeper] : Client environment:zookeeper.version=3.4.3-1240972, built on 02/06/2012 10:48 GMT
      [org.apache.zookeeper.ZooKeeper] : Client environment:host.name=jasons-mbp.home
      [org.apache.zookeeper.ZooKeeper] : Client environment:java.version=1.7.0_25
      [org.apache.zookeeper.ZooKeeper] : Client environment:java.vendor=Oracle Corporation
      [org.apache.zookeeper.ZooKeeper] : Client environment:java.home=/Library/Java/JavaVirtualMachines/jdk1.7.0_25.jdk/Contents/Home/jre
      [org.apache.zookeeper.ZooKeeper] : Client environment:java.class.path=mq-client.jar
      [org.apache.zookeeper.ZooKeeper] : Client environment:java.library.path=/Users/jsherman/Library/Java/Extensions:/Library/Java/Extensions:/Network/Library/Java/Extensions:/System/Library/Java/Extensions:/usr/lib/java:.
      [org.apache.zookeeper.ZooKeeper] : Client environment:java.io.tmpdir=/var/folders/qw/lw80158d0fvczz7bjz7njb680000gn/T/
      [org.apache.zookeeper.ZooKeeper] : Client environment:java.compiler=<NA>
      [org.apache.zookeeper.ZooKeeper] : Client environment:os.name=Mac OS X
      [org.apache.zookeeper.ZooKeeper] : Client environment:os.arch=x86_64
      [org.apache.zookeeper.ZooKeeper] : Client environment:os.version=10.9.3
      [org.apache.zookeeper.ZooKeeper] : Client environment:user.name=jsherman
      [org.apache.zookeeper.ZooKeeper] : Client environment:user.home=/Users/jsherman
      [org.apache.zookeeper.ZooKeeper] : Client environment:user.dir=/Users/jsherman/Development/tools/jboss-amq/jboss-a-mq-6.0.0.redhat-024/extras
      [org.apache.zookeeper.ZooKeeper] : Initiating client connection, connectString=localhost:2181 sessionTimeout=10000 watcher=org.fusesource.fabric.zookeeper.internal.ZKClient@18affbf6
      [org.apache.zookeeper.ClientCnxn] : Opening socket connection to server /127.0.0.1:2181
      [org.apache.zookeeper.client.ZooKeeperSaslClient] : Client will not SASL-authenticate because the default JAAS configuration section 'Client' could not be found. If you are not using SASL, you may ignore this. On the other hand, if you expected SASL to work, please fix your JAAS configuration.
      [org.apache.zookeeper.ClientCnxn] : Socket connection established to localhost/127.0.0.1:2181, initiating session
      [org.apache.zookeeper.ClientCnxn] : Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x14687807450000e, negotiated timeout = 10000
      org.codehaus.jackson.map.exc.UnrecognizedPropertyException: Unrecognized field "container" (Class org.fusesource.mq.fabric.FabricDiscoveryAgent$ActiveMQNode), not marked as ignorable
      at [Source: java.io.ByteArrayInputStream@156f6adb; line: 1, column: 33] (through reference chain: org.fusesource.mq.fabric.ActiveMQNode["container"])
      at org.codehaus.jackson.map.exc.UnrecognizedPropertyException.from(UnrecognizedPropertyException.java:53)
      at org.codehaus.jackson.map.deser.StdDeserializationContext.unknownFieldException(StdDeserializationContext.java:267)
      at org.codehaus.jackson.map.deser.std.StdDeserializer.reportUnknownProperty(StdDeserializer.java:673)
      at org.codehaus.jackson.map.deser.std.StdDeserializer.handleUnknownProperty(StdDeserializer.java:659)
      at org.codehaus.jackson.map.deser.BeanDeserializer.handleUnknownProperty(BeanDeserializer.java:1365)
      at org.codehaus.jackson.map.deser.BeanDeserializer._handleUnknown(BeanDeserializer.java:725)
      at org.codehaus.jackson.map.deser.BeanDeserializer.deserializeFromObject(BeanDeserializer.java:703)
      at org.codehaus.jackson.map.deser.BeanDeserializer.deserialize(BeanDeserializer.java:580)
      at org.codehaus.jackson.map.ObjectMapper._readMapAndClose(ObjectMapper.java:2732)
      at org.codehaus.jackson.map.ObjectMapper.readValue(ObjectMapper.java:1909)
      at org.fusesource.fabric.groups.ClusteredSupport$.decode(ClusteredSingleton.scala:62)
      at org.fusesource.fabric.groups.ClusteredSupport$.decode(ClusteredSingleton.scala:61)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher$$anon$2$$anonfun$changed$1.apply(ClusteredSingleton.scala:100)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher$$anon$2$$anonfun$changed$1.apply(ClusteredSingleton.scala:97)
      at scala.collection.Iterator$class.foreach(Iterator.scala:660)
      at scala.collection.JavaConversions$JMapWrapperLike$$anon$2.foreach(JavaConversions.scala:781)
      at scala.collection.IterableLike$class.foreach(IterableLike.scala:73)
      at scala.collection.JavaConversions$JMapWrapper.foreach(JavaConversions.scala:792)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher$$anon$2.changed(ClusteredSingleton.scala:97)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher$$anon$2.connected(ClusteredSingleton.scala:111)
      at org.fusesource.fabric.groups.internal.ChangeListenerSupport$class.add(ChangeListenerSupport.scala:45)
      at org.fusesource.fabric.groups.internal.ZooKeeperGroup.add(ZooKeeperGroup.scala:62)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher.start(ClusteredSingleton.scala:126)
      at org.fusesource.mq.fabric.FabricDiscoveryAgent.start(FabricDiscoveryAgent.java:258)
      at org.apache.activemq.transport.discovery.DiscoveryTransport.start(DiscoveryTransport.java:60)
      at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)
      at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)
      at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:273)
      at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:238)
      at org.apache.activemq.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:184)
      at org.fusesource.mq.ActiveMQService.start(ActiveMQService.java:89)
      at org.fusesource.mq.Main.execute(Main.java:110)
      at org.fusesource.mq.Main.main(Main.java:82)
      org.codehaus.jackson.map.exc.UnrecognizedPropertyException: Unrecognized field "container" (Class org.fusesource.mq.fabric.FabricDiscoveryAgent$ActiveMQNode), not marked as ignorable
      at [Source: java.io.ByteArrayInputStream@71fd03ab; line: 1, column: 33] (through reference chain: org.fusesource.mq.fabric.ActiveMQNode["container"])
      at org.codehaus.jackson.map.exc.UnrecognizedPropertyException.from(UnrecognizedPropertyException.java:53)
      at org.codehaus.jackson.map.deser.StdDeserializationContext.unknownFieldException(StdDeserializationContext.java:267)
      at org.codehaus.jackson.map.deser.std.StdDeserializer.reportUnknownProperty(StdDeserializer.java:673)
      at org.codehaus.jackson.map.deser.std.StdDeserializer.handleUnknownProperty(StdDeserializer.java:659)
      at org.codehaus.jackson.map.deser.BeanDeserializer.handleUnknownProperty(BeanDeserializer.java:1365)
      at org.codehaus.jackson.map.deser.BeanDeserializer._handleUnknown(BeanDeserializer.java:725)
      at org.codehaus.jackson.map.deser.BeanDeserializer.deserializeFromObject(BeanDeserializer.java:703)
      at org.codehaus.jackson.map.deser.BeanDeserializer.deserialize(BeanDeserializer.java:580)
      at org.codehaus.jackson.map.ObjectMapper._readMapAndClose(ObjectMapper.java:2732)
      at org.codehaus.jackson.map.ObjectMapper.readValue(ObjectMapper.java:1909)
      at org.fusesource.fabric.groups.ClusteredSupport$.decode(ClusteredSingleton.scala:62)
      at org.fusesource.fabric.groups.ClusteredSupport$.decode(ClusteredSingleton.scala:61)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher$$anon$2$$anonfun$changed$1.apply(ClusteredSingleton.scala:100)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher$$anon$2$$anonfun$changed$1.apply(ClusteredSingleton.scala:97)
      at scala.collection.Iterator$class.foreach(Iterator.scala:660)
      at scala.collection.JavaConversions$JMapWrapperLike$$anon$2.foreach(JavaConversions.scala:781)
      at scala.collection.IterableLike$class.foreach(IterableLike.scala:73)
      at scala.collection.JavaConversions$JMapWrapper.foreach(JavaConversions.scala:792)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher$$anon$2.changed(ClusteredSingleton.scala:97)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher$$anon$2.connected(ClusteredSingleton.scala:111)
      at org.fusesource.fabric.groups.internal.ChangeListenerSupport$class.add(ChangeListenerSupport.scala:45)
      at org.fusesource.fabric.groups.internal.ZooKeeperGroup.add(ZooKeeperGroup.scala:62)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher.start(ClusteredSingleton.scala:126)
      at org.fusesource.mq.fabric.FabricDiscoveryAgent.start(FabricDiscoveryAgent.java:258)
      at org.apache.activemq.transport.discovery.DiscoveryTransport.start(DiscoveryTransport.java:60)
      at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)
      at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)
      at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:273)
      at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:238)
      at org.apache.activemq.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:184)
      at org.fusesource.mq.ActiveMQService.start(ActiveMQService.java:89)
      at org.fusesource.mq.Main.execute(Main.java:110)
      at org.fusesource.mq.Main.main(Main.java:82)
      org.codehaus.jackson.map.exc.UnrecognizedPropertyException: Unrecognized field "container" (Class org.fusesource.mq.fabric.FabricDiscoveryAgent$ActiveMQNode), not marked as ignorable
      at [Source: java.io.ByteArrayInputStream@71f599ef; line: 1, column: 33] (through reference chain: org.fusesource.mq.fabric.ActiveMQNode["container"])
      at org.codehaus.jackson.map.exc.UnrecognizedPropertyException.from(UnrecognizedPropertyException.java:53)
      at org.codehaus.jackson.map.deser.StdDeserializationContext.unknownFieldException(StdDeserializationContext.java:267)
      at org.codehaus.jackson.map.deser.std.StdDeserializer.reportUnknownProperty(StdDeserializer.java:673)
      at org.codehaus.jackson.map.deser.std.StdDeserializer.handleUnknownProperty(StdDeserializer.java:659)
      at org.codehaus.jackson.map.deser.BeanDeserializer.handleUnknownProperty(BeanDeserializer.java:1365)
      at org.codehaus.jackson.map.deser.BeanDeserializer._handleUnknown(BeanDeserializer.java:725)
      at org.codehaus.jackson.map.deser.BeanDeserializer.deserializeFromObject(BeanDeserializer.java:703)
      at org.codehaus.jackson.map.deser.BeanDeserializer.deserialize(BeanDeserializer.java:580)
      at org.codehaus.jackson.map.ObjectMapper._readMapAndClose(ObjectMapper.java:2732)
      at org.codehaus.jackson.map.ObjectMapper.readValue(ObjectMapper.java:1909)
      at org.fusesource.fabric.groups.ClusteredSupport$.decode(ClusteredSingleton.scala:62)
      at org.fusesource.fabric.groups.ClusteredSupport$.decode(ClusteredSingleton.scala:61)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher$$anon$2$$anonfun$changed$1.apply(ClusteredSingleton.scala:100)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher$$anon$2$$anonfun$changed$1.apply(ClusteredSingleton.scala:97)
      at scala.collection.Iterator$class.foreach(Iterator.scala:660)
      at scala.collection.JavaConversions$JMapWrapperLike$$anon$2.foreach(JavaConversions.scala:781)
      at scala.collection.IterableLike$class.foreach(IterableLike.scala:73)
      at scala.collection.JavaConversions$JMapWrapper.foreach(JavaConversions.scala:792)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher$$anon$2.changed(ClusteredSingleton.scala:97)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher$$anon$2.connected(ClusteredSingleton.scala:111)
      at org.fusesource.fabric.groups.internal.ChangeListenerSupport$class.add(ChangeListenerSupport.scala:45)
      at org.fusesource.fabric.groups.internal.ZooKeeperGroup.add(ZooKeeperGroup.scala:62)
      at org.fusesource.fabric.groups.ClusteredSingletonWatcher.start(ClusteredSingleton.scala:126)
      at org.fusesource.mq.fabric.FabricDiscoveryAgent.start(FabricDiscoveryAgent.java:258)
      at org.apache.activemq.transport.discovery.DiscoveryTransport.start(DiscoveryTransport.java:60)
      at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)
      at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58)
      at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:273)
      at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:238)
      at org.apache.activemq.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:184)
      at org.fusesource.mq.ActiveMQService.start(ActiveMQService.java:89)
      at org.fusesource.mq.Main.execute(Main.java:110)
      at org.fusesource.mq.Main.main(Main.java:82)
      [org.fusesource.fabric.groups.internal.ChangeListenerSupport] : listeners are taking too long to process the events

      Attachments

        Activity

          People

            fbolton@redhat.com Fintan Bolton (Inactive)
            rhn-support-jsherman Jason Sherman
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: