activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Joe Fernandez (JIRA)" <j...@apache.org>
Subject [jira] Created: (AMQ-1464) AMQ 5.0 Fanout Regression
Date Mon, 15 Oct 2007 18:14:23 GMT
AMQ 5.0 Fanout Regression  
---------------------------

                 Key: AMQ-1464
                 URL: https://issues.apache.org/activemq/browse/AMQ-1464
             Project: ActiveMQ
          Issue Type: Bug
          Components: JMS client
    Affects Versions: 5.0.0
         Environment: AMQ 5.0 - the 10/10/07 SNAPSHOT
            Reporter: Joe Fernandez
             Fix For: 4.1.1


On 4.1.1, the fanout transport works as expected. My producer is fanning out message sends
(queues) to two unrelated message brokers and clients connected to both those brokers get
the messages.

However, when I run the same exact test under 5.0 (the 10/10 SNAPSHOT), fanout no longer works
as expected   Only the 5.0 broker that my producer first connects with gets the messages.
The second broker never gets the messages and hurls this exception.

ERROR Service      - Async error occurred: java.lang.IllegalStateException: Cannot remove
a consumer that had not been registered: ID:DIEGO-3739-1192470567781-0:0:-1:1
java.lang.IllegalStateException: Cannot remove a consumer that had not been registered: ID:DIEGO-3739-1192470567781-0:0:-1:1
        at org.apache.activemq.broker.TransportConnection.processRemoveConsumer(
TransportConnection.java:547)
        at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:64)
        at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281)
        at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
        at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
        at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134)
        at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:124)
        at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
        at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:183)
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:170)
        at java.lang.Thread.run(Thread.java:595)

Joe
 

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message