You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Jar Lyons (JIRA)" <ji...@apache.org> on 2009/04/21 23:57:31 UTC

[jira] Created: (AMQ-2218) Message delivery to consumer eventually pauses if consumer publishes to the same queue it receives from

Message delivery to consumer eventually pauses if consumer publishes to the same queue it receives from
-------------------------------------------------------------------------------------------------------

                 Key: AMQ-2218
                 URL: https://issues.apache.org/activemq/browse/AMQ-2218
             Project: ActiveMQ
          Issue Type: Bug
          Components: Broker
    Affects Versions: 5.3.0
         Environment: Windows XP Professional 2002, Service Pack 2,  Intel Pentium D 3ghz, various 1.5 and 1.6 versions of jdk
            Reporter: Jar Lyons
         Attachments: EchoConsumerLoadTest.java

I have written a test case which will demonstrate the following scenarios:

1. Simple producer driving a queue, simple consumer pulling from the queue.
2. Simple producer driving a queue, simple consumer pulling from the queue and producing an echo of the original message into the same queue.

Expected: message delivery should not be interrupted.

Actual: in scenario 2, eventually (about 500k messages in my environment), the delivery is halted to the consumer.

Test Output:

waiting for consumer to pause ... consumer: 0, producer: 0
waiting for consumer to pause ... consumer: 3738, producer: 29796
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841


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

[jira] Updated: (AMQ-2218) Message delivery to consumer eventually pauses if consumer publishes to the same queue it receives from

Posted by "Jar Lyons (JIRA)" <ji...@apache.org>.
     [ https://issues.apache.org/activemq/browse/AMQ-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jar Lyons updated AMQ-2218:
---------------------------

    Attachment: EchoConsumerLoadTest.java

> Message delivery to consumer eventually pauses if consumer publishes to the same queue it receives from
> -------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-2218
>                 URL: https://issues.apache.org/activemq/browse/AMQ-2218
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.3.0
>         Environment: Windows XP Professional 2002, Service Pack 2,  Intel Pentium D 3ghz, various 1.5 and 1.6 versions of jdk
>            Reporter: Jar Lyons
>         Attachments: EchoConsumerLoadTest.java
>
>
> I have written a test case which will demonstrate the following scenarios:
> 1. Simple producer driving a queue, simple consumer pulling from the queue.
> 2. Simple producer driving a queue, simple consumer pulling from the queue and producing an echo of the original message into the same queue.
> Expected: message delivery should not be interrupted.
> Actual: in scenario 2, eventually (about 500k messages in my environment), the delivery is halted to the consumer.
> Test Output:
> waiting for consumer to pause ... consumer: 0, producer: 0
> waiting for consumer to pause ... consumer: 3738, producer: 29796
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841

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

[jira] Updated: (AMQ-2218) Message delivery to consumer eventually pauses if consumer publishes to the same queue it receives from

Posted by "Bruce Snyder (JIRA)" <ji...@apache.org>.
     [ https://issues.apache.org/activemq/browse/AMQ-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Bruce Snyder updated AMQ-2218:
------------------------------

    Fix Version/s: 5.5.0
                       (was: 5.4.1)

> Message delivery to consumer eventually pauses if consumer publishes to the same queue it receives from
> -------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-2218
>                 URL: https://issues.apache.org/activemq/browse/AMQ-2218
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.3.0
>         Environment: Windows XP Professional 2002, Service Pack 2,  Intel Pentium D 3ghz, various 1.5 and 1.6 versions of jdk
>            Reporter: Jar Lyons
>             Fix For: 5.5.0
>
>         Attachments: EchoConsumerLoadTest.java
>
>
> I have written a test case which will demonstrate the following scenarios:
> 1. Simple producer driving a queue, simple consumer pulling from the queue.
> 2. Simple producer driving a queue, simple consumer pulling from the queue and producing an echo of the original message into the same queue.
> Expected: message delivery should not be interrupted.
> Actual: in scenario 2, eventually (about 500k messages in my environment), the delivery is halted to the consumer.
> Test Output:
> waiting for consumer to pause ... consumer: 0, producer: 0
> waiting for consumer to pause ... consumer: 3738, producer: 29796
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841
> waiting for consumer to pause ... consumer: 9224, producer: 67841

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