[jira] [Created] (AMQ-9119) ActiveMQ not sending `RemoveInfo` advisory message to AMQP advisory consumers when a consumer disconnects.

["Lucas Tétreault (Jira)" <ji...@apache.org>]

Lucas Tétreault created AMQ-9119:
------------------------------------

             Summary: ActiveMQ not sending `RemoveInfo` advisory message to AMQP advisory consumers when a consumer disconnects.
                 Key: AMQ-9119
                 URL: https://issues.apache.org/jira/browse/AMQ-9119
             Project: ActiveMQ
          Issue Type: Bug
          Components: AMQP
    Affects Versions: 5.16.0, 5.15.11
            Reporter: Lucas Tétreault
         Attachments: image-2022-10-12-18-37-41-001.png

When the consumer subscribed to the advisory topic uses AMQP it only receives "ConsumerInfo" (consumer=1) and never receives the "RemoveInfo" (consumer=0) message. If the consumer subscribed to the advisory topic uses Openwire both the "ConsumerInfo" and "RemoveInfo" messages are received as expected. This appears to be a regression related to AMQ-7068. 

 

In the logs we see an error like the following: 

{{WARN  AmqpSender                - Error detected while flushing outbound messages: No encoding is known for map entry value of type: org.apache.activemq.command.SessionId}}

 

We also noticed that the console shows the messages are Inflight but they are never received by the consumer: 

!image-2022-10-12-18-37-41-001.png|width=1627,height=478!

 

I have a fix and will prepare a PR right away. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)