You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "ASF subversion and git services (Jira)" <ji...@apache.org> on 2022/10/13 03:55:00 UTC

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

    [ https://issues.apache.org/jira/browse/AMQ-9119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616764#comment-17616764 ] 

ASF subversion and git services commented on AMQ-9119:
------------------------------------------------------

Commit 3bcbc5b847da43f97125490925335d7ce45b53e8 in activemq's branch refs/heads/main from Jean-Baptiste Onofré
[ https://gitbox.apache.org/repos/asf?p=activemq.git;h=3bcbc5b84 ]

Merge pull request #919 from lucastetreault/AMQ-9119

[AMQ-9119] Fix serialization of RemoveInfo advisory message for AMQP consumers

> 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.15.11, 5.16.0
>            Reporter: Lucas Tétreault
>            Assignee: Jean-Baptiste Onofré
>            Priority: Trivial
>             Fix For: 5.18.0, 5.16.6, 5.17.3
>
>         Attachments: image-2022-10-12-18-37-41-001.png
>
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> 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)