[ 
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)

Reply via email to