You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Dominic Tootell (Created) (JIRA)" <ji...@apache.org> on 2012/01/22 18:58:39 UTC
[jira] [Created] (AMQ-3674) TopicRegion removes durableScriber from
durableSubscriptions when it is active; but leaves subscription on Topic
TopicRegion removes durableScriber from durableSubscriptions when it is active; but leaves subscription on Topic
----------------------------------------------------------------------------------------------------------------
Key: AMQ-3674
URL: https://issues.apache.org/jira/browse/AMQ-3674
Project: ActiveMQ
Issue Type: Bug
Components: Broker
Affects Versions: 5.5.1
Environment: 5.5.1 (5.5.1-fuse-01-20), Mac OS X 10.7.2 (11.2.0 Darwin Kernel Version 11.2.0)
Reporter: Dominic Tootell
Priority: Minor
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java?revision=1160894&view=markup
Via the Web Admin Console you can attempt to remove a durable topic subscription when it is active; however you will receive the message: "Durable consumer is in use". However, there is unfortunate side effect of this attempt in that the *{{durableSubscriptions}}* map is modified and the subscription is removed from the map, and the topic is left with subscription. If you subsequentially then disconnect the active durable topic consumer (so it's in an active state; where you and attempt to remove the subscription), you cannot remove the inactive subscription as you hit: "No durable subscription exists for:"
{noformat}
@Override
public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
DurableTopicSubscription sub = durableSubscriptions.remove(key);
if (sub == null) {
throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
}
if (sub.isActive()) {
throw new JMSException("Durable consumer is in use");
}
{noformat}
The above maybe should be changed to, where the subscription is *{{get}}* from the map, and only removed if it's !sub.isActive(). (Or perhaps re add the subscription to the map if it is Active)
{noformat}
@Override
public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
DurableTopicSubscription sub = durableSubscriptions.get(key);
if (sub == null) {
throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
}
if (sub.isActive()) {
throw new JMSException("Durable consumer is in use");
}
if(sub!=null) {
durableSubscriptions.remove(key);
}
{noformat}
let me know if that makes no sense; and i'll try to create you a sample unit test.
cheers
/dom
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQ-3674) TopicRegion removes durableScriber
from durableSubscriptions when it is active; but leaves subscription on
Topic
Posted by "Dominic Tootell (Commented) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/AMQ-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13192594#comment-13192594 ]
Dominic Tootell commented on AMQ-3674:
--------------------------------------
Hi Tim,
Thanks for the feedback. Just wondering, should that else statement do a remove from the map; rather than the get?
{noformat}
} else {
182 durableSubscriptions.get(key);
183 }
{noformat}
i.e.
{noformat}
} else {
182 durableSubscriptions.remove(key);
183 }
{noformat}
cheers
/dom
> TopicRegion removes durableScriber from durableSubscriptions when it is active; but leaves subscription on Topic
> ----------------------------------------------------------------------------------------------------------------
>
> Key: AMQ-3674
> URL: https://issues.apache.org/jira/browse/AMQ-3674
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.5.1
> Environment: 5.5.1 (5.5.1-fuse-01-20), Mac OS X 10.7.2 (11.2.0 Darwin Kernel Version 11.2.0)
> Reporter: Dominic Tootell
> Assignee: Timothy Bish
> Priority: Minor
> Labels: Topic
> Fix For: 5.6.0
>
> Attachments: RemoveDurableSubscriptionTest.java, TopicRegion.AMQ-3674.patch.txt
>
>
> http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java?revision=1160894&view=markup
> Via the Web Admin Console you can attempt to remove a durable topic subscription when it is active; however you will receive the message: "Durable consumer is in use". However, there is unfortunate side effect of this attempt in that the *{{durableSubscriptions}}* map is modified and the subscription is removed from the map, and the topic is left with subscription. If you subsequentially then disconnect the active durable topic consumer (so it's in an active state; where you and attempt to remove the subscription), you cannot remove the inactive subscription as you hit: "No durable subscription exists for:"
> {noformat}
> @Override
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.remove(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> {noformat}
> The above maybe should be changed to, where the subscription is *{{get}}* from the map, and only removed if it's !sub.isActive(). (Or perhaps re add the subscription to the map if it is Active)
> {noformat}
> @Override
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.get(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> if(sub!=null) {
> durableSubscriptions.remove(key);
> }
> {noformat}
> let me know if that makes no sense; and i'll try to create you a sample unit test.
> cheers
> /dom
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQ-3674) TopicRegion removes durableScriber
from durableSubscriptions when it is active; but leaves subscription on
Topic
Posted by "Dominic Tootell (Commented) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/AMQ-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13191563#comment-13191563 ]
Dominic Tootell commented on AMQ-3674:
--------------------------------------
Attached patch, and junit.
> TopicRegion removes durableScriber from durableSubscriptions when it is active; but leaves subscription on Topic
> ----------------------------------------------------------------------------------------------------------------
>
> Key: AMQ-3674
> URL: https://issues.apache.org/jira/browse/AMQ-3674
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.5.1
> Environment: 5.5.1 (5.5.1-fuse-01-20), Mac OS X 10.7.2 (11.2.0 Darwin Kernel Version 11.2.0)
> Reporter: Dominic Tootell
> Priority: Minor
> Labels: Topic
> Attachments: RemoveDurableSubscriptionTest.java, TopicRegion.AMQ-3674.patch.txt
>
>
> http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java?revision=1160894&view=markup
> Via the Web Admin Console you can attempt to remove a durable topic subscription when it is active; however you will receive the message: "Durable consumer is in use". However, there is unfortunate side effect of this attempt in that the *{{durableSubscriptions}}* map is modified and the subscription is removed from the map, and the topic is left with subscription. If you subsequentially then disconnect the active durable topic consumer (so it's in an active state; where you and attempt to remove the subscription), you cannot remove the inactive subscription as you hit: "No durable subscription exists for:"
> {noformat}
> @Override
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.remove(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> {noformat}
> The above maybe should be changed to, where the subscription is *{{get}}* from the map, and only removed if it's !sub.isActive(). (Or perhaps re add the subscription to the map if it is Active)
> {noformat}
> @Override
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.get(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> if(sub!=null) {
> durableSubscriptions.remove(key);
> }
> {noformat}
> let me know if that makes no sense; and i'll try to create you a sample unit test.
> cheers
> /dom
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-3674) TopicRegion removes durableScriber from
durableSubscriptions when it is active; but leaves subscription on Topic
Posted by "Dominic Tootell (Updated) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/AMQ-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dominic Tootell updated AMQ-3674:
---------------------------------
Attachment: TopicRegion.AMQ-3674.patch.txt
RemoveDurableSubscriptionTest.java
> TopicRegion removes durableScriber from durableSubscriptions when it is active; but leaves subscription on Topic
> ----------------------------------------------------------------------------------------------------------------
>
> Key: AMQ-3674
> URL: https://issues.apache.org/jira/browse/AMQ-3674
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.5.1
> Environment: 5.5.1 (5.5.1-fuse-01-20), Mac OS X 10.7.2 (11.2.0 Darwin Kernel Version 11.2.0)
> Reporter: Dominic Tootell
> Priority: Minor
> Labels: Topic
> Attachments: RemoveDurableSubscriptionTest.java, TopicRegion.AMQ-3674.patch.txt
>
>
> http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java?revision=1160894&view=markup
> Via the Web Admin Console you can attempt to remove a durable topic subscription when it is active; however you will receive the message: "Durable consumer is in use". However, there is unfortunate side effect of this attempt in that the *{{durableSubscriptions}}* map is modified and the subscription is removed from the map, and the topic is left with subscription. If you subsequentially then disconnect the active durable topic consumer (so it's in an active state; where you and attempt to remove the subscription), you cannot remove the inactive subscription as you hit: "No durable subscription exists for:"
> {noformat}
> @Override
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.remove(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> {noformat}
> The above maybe should be changed to, where the subscription is *{{get}}* from the map, and only removed if it's !sub.isActive(). (Or perhaps re add the subscription to the map if it is Active)
> {noformat}
> @Override
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.get(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> if(sub!=null) {
> durableSubscriptions.remove(key);
> }
> {noformat}
> let me know if that makes no sense; and i'll try to create you a sample unit test.
> cheers
> /dom
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQ-3674) TopicRegion removes durableScriber
from durableSubscriptions when it is active; but leaves subscription on
Topic
Posted by "Timothy Bish (Commented) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/AMQ-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13192615#comment-13192615 ]
Timothy Bish commented on AMQ-3674:
-----------------------------------
Good catch, fixed it.
> TopicRegion removes durableScriber from durableSubscriptions when it is active; but leaves subscription on Topic
> ----------------------------------------------------------------------------------------------------------------
>
> Key: AMQ-3674
> URL: https://issues.apache.org/jira/browse/AMQ-3674
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.5.1
> Environment: 5.5.1 (5.5.1-fuse-01-20), Mac OS X 10.7.2 (11.2.0 Darwin Kernel Version 11.2.0)
> Reporter: Dominic Tootell
> Assignee: Timothy Bish
> Priority: Minor
> Labels: Topic
> Fix For: 5.6.0
>
> Attachments: RemoveDurableSubscriptionTest.java, TopicRegion.AMQ-3674.patch.txt
>
>
> http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java?revision=1160894&view=markup
> Via the Web Admin Console you can attempt to remove a durable topic subscription when it is active; however you will receive the message: "Durable consumer is in use". However, there is unfortunate side effect of this attempt in that the *{{durableSubscriptions}}* map is modified and the subscription is removed from the map, and the topic is left with subscription. If you subsequentially then disconnect the active durable topic consumer (so it's in an active state; where you and attempt to remove the subscription), you cannot remove the inactive subscription as you hit: "No durable subscription exists for:"
> {noformat}
> @Override
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.remove(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> {noformat}
> The above maybe should be changed to, where the subscription is *{{get}}* from the map, and only removed if it's !sub.isActive(). (Or perhaps re add the subscription to the map if it is Active)
> {noformat}
> @Override
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.get(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> if(sub!=null) {
> durableSubscriptions.remove(key);
> }
> {noformat}
> let me know if that makes no sense; and i'll try to create you a sample unit test.
> cheers
> /dom
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Resolved] (AMQ-3674) TopicRegion removes durableScriber
from durableSubscriptions when it is active; but leaves subscription on
Topic
Posted by "Timothy Bish (Resolved) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/AMQ-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Timothy Bish resolved AMQ-3674.
-------------------------------
Resolution: Fixed
Fix Version/s: 5.6.0
Assignee: Timothy Bish
Simplified the test case and patch a little and applied. Thanks!
> TopicRegion removes durableScriber from durableSubscriptions when it is active; but leaves subscription on Topic
> ----------------------------------------------------------------------------------------------------------------
>
> Key: AMQ-3674
> URL: https://issues.apache.org/jira/browse/AMQ-3674
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.5.1
> Environment: 5.5.1 (5.5.1-fuse-01-20), Mac OS X 10.7.2 (11.2.0 Darwin Kernel Version 11.2.0)
> Reporter: Dominic Tootell
> Assignee: Timothy Bish
> Priority: Minor
> Labels: Topic
> Fix For: 5.6.0
>
> Attachments: RemoveDurableSubscriptionTest.java, TopicRegion.AMQ-3674.patch.txt
>
>
> http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java?revision=1160894&view=markup
> Via the Web Admin Console you can attempt to remove a durable topic subscription when it is active; however you will receive the message: "Durable consumer is in use". However, there is unfortunate side effect of this attempt in that the *{{durableSubscriptions}}* map is modified and the subscription is removed from the map, and the topic is left with subscription. If you subsequentially then disconnect the active durable topic consumer (so it's in an active state; where you and attempt to remove the subscription), you cannot remove the inactive subscription as you hit: "No durable subscription exists for:"
> {noformat}
> @Override
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.remove(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> {noformat}
> The above maybe should be changed to, where the subscription is *{{get}}* from the map, and only removed if it's !sub.isActive(). (Or perhaps re add the subscription to the map if it is Active)
> {noformat}
> @Override
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.get(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> if(sub!=null) {
> durableSubscriptions.remove(key);
> }
> {noformat}
> let me know if that makes no sense; and i'll try to create you a sample unit test.
> cheers
> /dom
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQ-3674) TopicRegion removes durableScriber
from durableSubscriptions when it is active; but leaves subscription on
Topic
Posted by "Timothy Bish (Commented) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/AMQ-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13191163#comment-13191163 ]
Timothy Bish commented on AMQ-3674:
-----------------------------------
This seems valid, a test case and a supplied patch to resolved the issue would be a nice contribution.
> TopicRegion removes durableScriber from durableSubscriptions when it is active; but leaves subscription on Topic
> ----------------------------------------------------------------------------------------------------------------
>
> Key: AMQ-3674
> URL: https://issues.apache.org/jira/browse/AMQ-3674
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.5.1
> Environment: 5.5.1 (5.5.1-fuse-01-20), Mac OS X 10.7.2 (11.2.0 Darwin Kernel Version 11.2.0)
> Reporter: Dominic Tootell
> Priority: Minor
> Labels: Topic
>
> http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java?revision=1160894&view=markup
> Via the Web Admin Console you can attempt to remove a durable topic subscription when it is active; however you will receive the message: "Durable consumer is in use". However, there is unfortunate side effect of this attempt in that the *{{durableSubscriptions}}* map is modified and the subscription is removed from the map, and the topic is left with subscription. If you subsequentially then disconnect the active durable topic consumer (so it's in an active state; where you and attempt to remove the subscription), you cannot remove the inactive subscription as you hit: "No durable subscription exists for:"
> {noformat}
> @Override
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.remove(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> {noformat}
> The above maybe should be changed to, where the subscription is *{{get}}* from the map, and only removed if it's !sub.isActive(). (Or perhaps re add the subscription to the map if it is Active)
> {noformat}
> @Override
> public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
> SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
> DurableTopicSubscription sub = durableSubscriptions.get(key);
> if (sub == null) {
> throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
> }
> if (sub.isActive()) {
> throw new JMSException("Durable consumer is in use");
> }
> if(sub!=null) {
> durableSubscriptions.remove(key);
> }
> {noformat}
> let me know if that makes no sense; and i'll try to create you a sample unit test.
> cheers
> /dom
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira