MSG Open ActiveMQ Bugs

Our open support cases

• DEV-2294- Duplicate messages warnings for topics with network of brokers + kahaDB

Our Bugs

• AMQ-2301 - Connection view in ActiveMQ web console lists empty lines
• AMQ-2302 - enqueue count, dequeue count and dispatch queue size always 0 for any connections shown in the ActiveMQ web console - fixed in AMQ-5.3.0
• AMQ-2314, MB-553 - tmp_storage is not clean up once a slow subscriber is disconnected. - Fixed in 5.3.0.5
• MB-552, AMQ-2249 - Peer certificates not propagated when using stomp+ssl w/mutual authentication - Fixed in 5.3.0.5
• MB-585, AMQ-2474 - In a a network of brokers cannot setup SSL connections between brokers - Fixed in 5.3.0.5
• DEV-2258, MB-646 - JMX MBean name has spurious space for durable subscription

Other Bugs

• AMQ-2303 - Durable consumers recovery - Fixed in AMQ-5.3.0

• MB-531 - staticallyIncludedDestinations set in a Network of Brokers results in duplicate messages - Fixed in 5.3.0.5

• AMQ-2489 Could not correlate acknowledgment with dispatched message" exception - Fixed in AMQ-5.3.1

• AMQ-2475 Message Broker Hangs When Temp Store Fills - fixed in AMQ-5.4.0

Bugs to file

• turning on <traceBrokerPathPlugin/> in VTB network causes duplicates (and strange routing)

 Received : MESSAGE
Header   : expires: 0
Header   : BrokerPath: vtb-generic-28.cern.ch,vtb-generic-28.cern.ch,vtb-generic-28.cern.ch,vtb-generic-27.cern.ch,vtb-generic-27.cern.ch
Header   : timestamp: 1259149376776
Header   : destination: /topic/grid.foo2
Header   : priority: 0
Header   : receipt: message-0
Header   : message-id: ID:vtb-generic-28.cern.ch-33670-1259147880851-6:15:-1:1:1
Body     :      'testing! 0'
Received : MESSAGE
Header   : expires: 0
Header   : BrokerPath: vtb-generic-28.cern.ch,vtb-generic-27.cern.ch
Header   : timestamp: 1259149376776
Header   : destination: /topic/grid.foo2
Header   : priority: 0
Header   : receipt: message-0
Header   : message-id: ID:vtb-generic-28.cern.ch-33670-1259147880851-6:15:-1:1:1
Body     :      'testing! 0'

• Can't set prefetch on network connectors
• JMSXUserID set with broker ID when using SSL for network connectors and publisher/subscribers are on different brokers (and not set at all for pub/sub on same broker)
• maximumConnections option on stomp transport does not throw exception when exceeded. (fix in https://issues.apache.org/activemq/browse/AMQ-1928 doesn't seem to work for STOMP).
• temp-topic does not return the destination header in same way that queue does:

11:06:06[src]vtb-generi$./temp_dest_example -p 6163
subscribing to '/temp-queue/foobar'
Have actual destination '/remote-temp-queue/ID:gridmsg001.cern.ch-43557-1257760349861-3:24:1'
11:06:26[src]vtb-generi$./temp_dest_example -p 6163
subscribing to '/temp-topic/foobar'
Have actual destination '/temp-topic/foobar'

• Problems when trying to tune policies for dispatch :

 <policyEntry queue=">" memoryLimit="1mb">
<pendingQueuePolicy>
              <fileQueueCursor />
            </pendingQueuePolicy>

     </policyEntry>

       <policyEntry topic=">" memoryLimit="1mb">
<pendingSubscriberPolicy>
              <fileCursor />
            </pendingSubscriberPolicy>
            <pendingDurableSubscriberPolicy>
              <fileDurableSubscriberCursor />
            </pendingDurableSubscriberPolicy>
        </policyEntry>  

2009-11-10 16:54:40,579 [erSimpleAppMain] ERROR BrokerService                  - Failed to start ActiveMQ JMS Message Broker. Reason: java.lang.ClassCastException: org.apache.activemq.kaha.i
mpl.index.IndexItem cannot be cast to java.lang.Comparable
java.lang.ClassCastException: org.apache.activemq.kaha.impl.index.IndexItem cannot be cast to java.lang.Comparable
        at org.apache.activemq.kaha.impl.index.hash.HashIndex.get(HashIndex.java:293)
        at org.apache.activemq.kaha.impl.container.MapContainerImpl.get(MapContainerImpl.java:212)
        at org.apache.activemq.store.kahadaptor.KahaTopicMessageStore.recoverSubscription(KahaTopicMessageStore.java:143)
        at org.apache.activemq.store.ProxyTopicMessageStore.recoverSubscription(ProxyTopicMessageStore.java:92)
        at org.apache.activemq.broker.region.Topic.activate(Topic.java:226)
        at org.apache.activemq.broker.region.DurableTopicSubscription.add(DurableTopicSubscription.java:88)
        at org.apache.activemq.broker.region.Topic.addSubscription(Topic.java:151)
        at org.apache.activemq.broker.region.TopicRegion.addSubscriptionsForDestination(TopicRegion.java:192)
        at org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:129)
        at org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:269)
        at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:142)
        at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:142)
        at org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:149)
        at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:142)
        at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:142)
        at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:142)
        at org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:149)
        at org.apache.activemq.broker.region.AbstractRegion.start(AbstractRegion.java:94)
        at org.apache.activemq.broker.region.RegionBroker.start(RegionBroker.java:177)
        at org.apache.activemq.broker.jmx.ManagedRegionBroker.start(ManagedRegionBroker.java:103)
        at org.apache.activemq.broker.TransactionBroker.start(TransactionBroker.java:112)
        at org.apache.activemq.broker.BrokerFilter.start(BrokerFilter.java:154)
        at org.apache.activemq.broker.BrokerFilter.start(BrokerFilter.java:154)
        at org.apache.activemq.broker.BrokerFilter.start(BrokerFilter.java:154)
        at org.apache.activemq.broker.BrokerFilter.start(BrokerFilter.java:154)
        at org.apache.activemq.broker.BrokerService$3.start(BrokerService.java:1719)
        at org.apache.activemq.broker.BrokerService.start(BrokerService.java:471)
        at org.apache.activemq.xbean.XBeanBrokerService.afterPropertiesSet(XBeanBrokerService.java:56)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1368)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1334)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:473)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory$1.run(AbstractAutowireCapableBeanFactory.java:409)
        at java.security.AccessController.doPrivileged(Native Method)
        at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:380)
        at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:264)
        at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:221)        at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:261)
        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:185)
        at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:164)        at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:429)
        at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:729)
        at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:381)
        at org.apache.xbean.spring.context.ResourceXmlApplicationContext.<init>(ResourceXmlApplicationContext.java:64)
        at org.apache.xbean.spring.context.ResourceXmlApplicationContext.<init>(ResourceXmlApplicationContext.java:52)
        at org.apache.activemq.xbean.XBeanBrokerFactory.createApplicationContext(XBeanBrokerFactory.java:96)
        at org.apache.activemq.xbean.XBeanBrokerFactory.createBroker(XBeanBrokerFactory.java:52)
        at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.java:71)
        at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.java:54)
        at org.apache.activemq.console.command.StartCommand.startBroker(StartCommand.java:115)
        at org.apache.activemq.console.command.StartCommand.runTask(StartCommand.java:91)

• using Nagios plugin check_tcp to ping the Messaging Broker port 6167 (OpenWire SSL) ActiveMQ raise an exception. It doesn't generate any exception on port 6162 (STOMP SSL).

check_tcp -H <hostname> -p 6167

2009-12-16 13:04:23,389 [141.72.90:36515] ERROR TransportConnector             - Could not accept connection : javax.net.ssl.SSLHandshakeException: Remote host closed connection during handshake