Uploaded image for project: 'ActiveMQ C++ Client'
  1. ActiveMQ C++ Client
  2. AMQCPP-243

Error when acknowledging messages that are sent to Virtual Topic subscribers

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 3.0
    • 3.0
    • Openwire
    • None

    Description

      When acknowledging messages sent to subscribers on a Queue that is receiving messages sent to a Virtual Topic the broker generates an error.

      ERROR Service                        - Async error occurred: java.lang.IllegalArgumentException: The subscription does not exist: f845dcb8-e92c-90af-46d8-e5dbc29aacae:0:0
      java.lang.IllegalArgumentException: The subscription does not exist: f845dcb8-e92c-90af-46d8-e5dbc29aacae:0:0
      	at org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:364)
      	at org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:462)
      	at org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:194)
      	at org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74)
      	at org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:74)
      	at org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:85)
      	at org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:456)
      	at org.apache.activemq.command.MessageAck.visit(MessageAck.java:205)
      	at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:305)
      	at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
      	at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
      	at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
      	at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
      	at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
      	at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
      	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
      	at java.lang.Thread.run(Thread.java:636)
      
      

      Attachments

        Activity

          Resolved in trunk. There were two places where the ack message was getting the Destination from the Message assigned to it instead of the Destination from the MessageDispatch command.

          tabish Timothy A. Bish added a comment - Resolved in trunk. There were two places where the ack message was getting the Destination from the Message assigned to it instead of the Destination from the MessageDispatch command.

          Rolling this into the next 3.0 RC tag

          tabish Timothy A. Bish added a comment - Rolling this into the next 3.0 RC tag

          People

            tabish Timothy A. Bish
            tabish Timothy A. Bish
            Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: