You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Danielius Jurna (JIRA)" <ji...@apache.org> on 2006/11/29 13:58:03 UTC
[jira] Created: (AMQ-1077) Bug in STOMP transport unsubscribe
Bug in STOMP transport unsubscribe
----------------------------------
Key: AMQ-1077
URL: https://issues.apache.org/activemq/browse/AMQ-1077
Project: ActiveMQ
Issue Type: Bug
Components: Transport
Affects Versions: 4.0.2
Environment: linux 2.6, java 1.5
Reporter: Danielius Jurna
Attachments: patch.txt
After several ubscribe/unsubscribe commands to activemq, subscribtions are not removed and there's error log in the broker:
java.lang.IllegalStateException: Cannot remove a consumer that had not been registered: ID:das-32775-1164773607925-3:1881:-1:2
at org.apache.activemq.broker.AbstractConnection.processRemoveConsumer(AbstractConnection.java:551)
at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:64)
at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:237)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:61)
at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:123)
at org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:70)
at org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:112)
at org.apache.activemq.transport.stomp.ProtocolConverter.onStompUnsubscribe(ProtocolConverter.java:376)
at org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommad(ProtocolConverter.java:144)
at org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:60)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:88)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
at java.lang.Thread.run(Thread.java:595)
The problem is that there's internal map of subscriptions in ProtocolConverter class. On unsubscribe command, subscription is not removed from this internal map. Attached patch (against ProtocolConverter.java) fixes this bug
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] Commented: (AMQ-1077) Bug in STOMP transport unsubscribe
Posted by "Danielius Jurna (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-1077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#action_37904 ]
Danielius Jurna commented on AMQ-1077:
--------------------------------------
Is is possible for the provided patch to be applied for 4.2 version?
> Bug in STOMP transport unsubscribe
> ----------------------------------
>
> Key: AMQ-1077
> URL: https://issues.apache.org/activemq/browse/AMQ-1077
> Project: ActiveMQ
> Issue Type: Bug
> Components: Transport
> Affects Versions: 4.0.2
> Environment: linux 2.6, java 1.5
> Reporter: Danielius Jurna
> Attachments: patch.txt
>
>
> After several ubscribe/unsubscribe commands to activemq, subscribtions are not removed and there's error log in the broker:
> java.lang.IllegalStateException: Cannot remove a consumer that had not been registered: ID:das-32775-1164773607925-3:1881:-1:2
> at org.apache.activemq.broker.AbstractConnection.processRemoveConsumer(AbstractConnection.java:551)
> at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:64)
> at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:237)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:61)
> at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:123)
> at org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:70)
> at org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:112)
> at org.apache.activemq.transport.stomp.ProtocolConverter.onStompUnsubscribe(ProtocolConverter.java:376)
> at org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommad(ProtocolConverter.java:144)
> at org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:60)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:88)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
> at java.lang.Thread.run(Thread.java:595)
> The problem is that there's internal map of subscriptions in ProtocolConverter class. On unsubscribe command, subscription is not removed from this internal map. Attached patch (against ProtocolConverter.java) fixes this bug
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] Assigned: (AMQ-1077) Bug in STOMP transport unsubscribe
Posted by "Rob Davies (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-1077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Rob Davies reassigned AMQ-1077:
-------------------------------
Assignee: Rob Davies
> Bug in STOMP transport unsubscribe
> ----------------------------------
>
> Key: AMQ-1077
> URL: https://issues.apache.org/activemq/browse/AMQ-1077
> Project: ActiveMQ
> Issue Type: Bug
> Components: Transport
> Affects Versions: 4.0.2
> Environment: linux 2.6, java 1.5
> Reporter: Danielius Jurna
> Assigned To: Rob Davies
> Attachments: patch.txt
>
>
> After several ubscribe/unsubscribe commands to activemq, subscribtions are not removed and there's error log in the broker:
> java.lang.IllegalStateException: Cannot remove a consumer that had not been registered: ID:das-32775-1164773607925-3:1881:-1:2
> at org.apache.activemq.broker.AbstractConnection.processRemoveConsumer(AbstractConnection.java:551)
> at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:64)
> at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:237)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:61)
> at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:123)
> at org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:70)
> at org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:112)
> at org.apache.activemq.transport.stomp.ProtocolConverter.onStompUnsubscribe(ProtocolConverter.java:376)
> at org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommad(ProtocolConverter.java:144)
> at org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:60)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:88)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
> at java.lang.Thread.run(Thread.java:595)
> The problem is that there's internal map of subscriptions in ProtocolConverter class. On unsubscribe command, subscription is not removed from this internal map. Attached patch (against ProtocolConverter.java) fixes this bug
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Resolved: (AMQ-1077) Bug in STOMP transport unsubscribe
Posted by "Rob Davies (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-1077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Rob Davies resolved AMQ-1077.
-----------------------------
Resolution: Fixed
Fix Version/s: 4.2.0
resolved by SVN revision 499032
> Bug in STOMP transport unsubscribe
> ----------------------------------
>
> Key: AMQ-1077
> URL: https://issues.apache.org/activemq/browse/AMQ-1077
> Project: ActiveMQ
> Issue Type: Bug
> Components: Transport
> Affects Versions: 4.0.2
> Environment: linux 2.6, java 1.5
> Reporter: Danielius Jurna
> Assigned To: Rob Davies
> Fix For: 4.2.0
>
> Attachments: patch.txt
>
>
> After several ubscribe/unsubscribe commands to activemq, subscribtions are not removed and there's error log in the broker:
> java.lang.IllegalStateException: Cannot remove a consumer that had not been registered: ID:das-32775-1164773607925-3:1881:-1:2
> at org.apache.activemq.broker.AbstractConnection.processRemoveConsumer(AbstractConnection.java:551)
> at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:64)
> at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:237)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:61)
> at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:123)
> at org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:70)
> at org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:112)
> at org.apache.activemq.transport.stomp.ProtocolConverter.onStompUnsubscribe(ProtocolConverter.java:376)
> at org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommad(ProtocolConverter.java:144)
> at org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:60)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:88)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
> at java.lang.Thread.run(Thread.java:595)
> The problem is that there's internal map of subscriptions in ProtocolConverter class. On unsubscribe command, subscription is not removed from this internal map. Attached patch (against ProtocolConverter.java) fixes this bug
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.