Mailing-List: contact activemq-dev-help@geronimo.apache.org; run by ezmlm
Precedence: bulk
Reply-To: activemq-dev@geronimo.apache.org
Message-ID: <8586657.1169562679931.JavaMail.jira@brutus>
Date: Tue, 23 Jan 2007 06:31:19 -0800 (PST)
From: "Rob Davies (JIRA)" <jira@apache.org>
To: activemq-dev@geronimo.apache.org
Subject: [jira] Resolved: (AMQ-1077) Bug in STOMP transport unsubscribe
In-Reply-To: <30391421.1164805083112.JavaMail.root@brutus>
MIME-Version: 1.0
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: 7bit


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