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

• Type: Bug
• Status: Resolved
• Priority: Trivial
• Resolution: Fixed
• Affects Version/s: 5.15.11, 5.16.0
• Fix Version/s: 5.18.0, 5.16.6, 5.17.3
• Component/s: AMQP
• Assignee: Jean-Baptiste Onofré
• Reporter: Lucas Tétreault
• Created: 13/Oct/22 01:38
• Updated: 13/Oct/22 03:55
• Resolved: 13/Oct/22 03:55

Description

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: 

 

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