[jira] Reopened: (AMQ-1464) AMQ 5.0 Fanout Regression

["Gary Watson (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/activemq/browse/AMQ-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Gary Watson reopened AMQ-1464:
------------------------------


It appears that the Queues versus Topics issue has been resolved, with the addition of the new fanOutQueues option. However, the problem of java.lang.IllegalStateException remains.

I am using Topics with the 10/28/07 5.0 Snapshot. I have 2 standalone brokers, each connected to a Topic consumer. I start a Topic producer that uses fanout to connect to the 2 brokers. The messages that are sent by the producer are received by each consumer (good), but after the producer closes the session, one of the the brokers throws the exception "ERROR Service      - Async error occurred: java.lang.IllegalStateException: Cannot remove a consumer that had not been registered" as Joe reported.

> 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
>            Assignee: Hiram Chirino
>             Fix For: 5.0.0
>
>
> 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.