[jira] [Reopened] (AMQ-8023) Network bridge shutdown, race on MQTT virtual topic clean session and resubscribe

["Gary Tully (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/AMQ-8023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Gary Tully reopened AMQ-8023:
-----------------------------

There is another problem in AMQ2439Test that suggests the fix for the AMQ3274Test regression is not correct :( - on it.

> Network bridge shutdown, race on MQTT virtual topic clean session and resubscribe
> ---------------------------------------------------------------------------------
>
>                 Key: AMQ-8023
>                 URL: https://issues.apache.org/jira/browse/AMQ-8023
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: MQTT, Network of Brokers
>    Affects Versions: 5.16.0
>            Reporter: Gary Tully
>            Assignee: Gary Tully
>            Priority: Major
>             Fix For: 5.17.0
>
>
> With MQTT clients using virtual topic subscriptions and clean session. In a network of brokers when the remove destination operations are bridged, it is possible for the re-subscribe to beat the removeDestination advisory and cause the remove to fail with an error, causing the bridge to fail. The advisories are in order, but are executed out of order on the remote network bridge, in error.
> {code:java}
> WARN  | pool-16-thread-1 | Service   | ivemq.broker.TransportConnection  304 | 162 - org.apache.activemq.activemq-osgi | Async error occurred: javax.jms.JMSException: Destination still has an active subscription: queue://Consumer.340601550021719:AT_LEAST_ONCE.VirtualTopic.IMPORTANT.>
> INFO  | Task-310 | DemandForwardingBridgeSupport    | rk.DemandForwardingBridgeSupport  908 | 162 - org.apache.activemq.activemq-osgi | Network connection between vm://AMQ1 and ssl:///x.x.x:x shutdown due to a local error: javax.jms.JMSException: Destination still has an active subscription: queue://Consumer.340601550021719:AT_LEAST_ONCE.VirtualTopic.IMPORTANT.>
> {code}
>  Two necessary config options:
> # networkConnector destinationFilter="ActiveMQ.Advisory.Consumer.Queue.>,ActiveMQ.Advisory.Queue"
> # &transport.subscriptionStrategy=mqtt-virtual-topic-subscriptions



--
This message was sent by Atlassian Jira
(v8.3.4#803005)