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

These generally need a test case still
  • 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>  
leads to
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
generate this in activemq.log
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
Edit | Attach | Watch | Print version | History: r23 < r22 < r21 < r20 < r19 | Backlinks | Raw View | WYSIWYG | More topic actions
Topic revision: r23 - 2010-04-29 - unknown
 
    • Cern Search Icon Cern Search
    • TWiki Search Icon TWiki Search
    • Google Search Icon Google Search

    EGEE All webs login

This site is powered by the TWiki collaboration platform Powered by Perl This site is powered by the TWiki collaboration platformCopyright & by the contributing authors. All material on this collaboration platform is the property of the contributing authors.
Ideas, requests, problems regarding TWiki? Ask a support question or Send feedback