Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-2024

Disabling Advisory generates WARN messages :"Errors occurred during the buffering operation : javax.jms.IllegalStateException: Cannot remove a consumer that had not been registered:" every time the XA recovery happens.

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • AMQ 7.2.4.GA
    • AMQ 7.2.1.GA
    • openwire-protocol
    • None
    • Hide
      In prior releases, when advisory messages were disabled on the broker, the broker ignored client requests to create advisory consumers and made no record of these consumers. If clients attempted to query these consumers, you saw an exception. This issue is corrected. The broker now creates records of advisory consumers when clients request them, and subsequent operations are successful.
      Show
      In prior releases, when advisory messages were disabled on the broker, the broker ignored client requests to create advisory consumers and made no record of these consumers. If clients attempted to query these consumers, you saw an exception. This issue is corrected. The broker now creates records of advisory consumers when clients request them, and subsequent operations are successful.
    • Hide

      Attached configuration along with a sample application to reproduce the issue.

      Show
      Attached configuration along with a sample application to reproduce the issue.

    Description

      When connecting EAP 6.4 with AMQ 7.x using AMQ 6.x rar(openwire) and disabling the Advisory*(supportAdvisory=false)* generates lots of below WARN messages every time XA recovery happens.

      2018-09-28 12:46:41,459 WARN  [org.apache.activemq.artemis.core.server] Errors occurred during the buffering operation : javax.jms.IllegalStateException: Cannot remove a consumer that had not been registered: ID:localhost.localdomain-40078-1538117722646-139:1:-1:1
      	at org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection$CommandProcessor.processRemoveConsumer(OpenWireConnection.java:1639) [artemis-openwire-protocol-2.6.3.redhat-00004.jar:]
      	at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:77) [activemq-client-5.11.0.redhat-630329.jar:5.11.0.redhat-630329]
      	at org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection.bufferReceived(OpenWireConnection.java:291) [artemis-openwire-protocol-2.6.3.redhat-00004.jar:]
      	at org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:643) [artemis-server-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
      	at org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:73) [artemis-core-client-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
      	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:808) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:408) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:308) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884) [netty-all-4.1.25.Final-redhat-00003.jar:4.1.25.Final-redhat-00003]
      	at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.6.3.redhat-00004.jar:2.6.3.redhat-00004]
      
      

      supportAdvisory=true, does not have any issue.

      Attachments

        1. QueueExample.java
          1 kB
          Shailendra Singh

        Activity

          People

            gaohoward Howard Gao
            rhn-support-shsingh Shailendra Singh
            Michal Toth Michal Toth
            Votes:
            1 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Time Tracking

                Estimated:
                Original Estimate - 0 minutes
                0m
                Remaining:
                Remaining Estimate - 0 minutes
                0m
                Logged:
                Time Spent - 1 day
                1d