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)
