You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Joe Roberts (JIRA)" <ji...@apache.org> on 2012/07/26 23:24:35 UTC

[jira] [Created] (AMQ-3948) Multiple consumers retrieving same message from ActiveMQ

Joe Roberts created AMQ-3948:
--------------------------------

             Summary: Multiple consumers retrieving same message from ActiveMQ
                 Key: AMQ-3948
                 URL: https://issues.apache.org/jira/browse/AMQ-3948
             Project: ActiveMQ
          Issue Type: Bug
          Components: Broker
    Affects Versions: 5.4.3
         Environment: ActiveMQ 5.4.3 running on 64-bit Windows 7 OS. 64-bit JDK. 
            Reporter: Joe Roberts
             Fix For: NEEDS_REVIEWED


We have a java web-service (running in Jetty) that dynamically instantiates an ActiveMQ queue and send messages to the queue - the messages are integers (i.e. 1, 2, 3, etc). We have from one to many consumers that read from this queue to process these messages. Each consumer is started from a single process but each consumer is running in it's own thread or process. When we have multiple consumers running, they occasionally will pick up the same integer or message from the queue. This is not desired. If a consumer reads a message, we don't want other consumers to retrieve that same message. We're fairly new to ActiveMQ but those we're telling about this issue said it should not be happening. They think it might be that we have an ActiveMQ configuration issue. Could be we need to set a property to prevent this. Just looking for some help. I've attached our applicationContext-mcp-parallelization-activemq XML. We could have configured this incorrectly. We're using the internalAmqConnectionFactory for this queue.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

       

[jira] [Commented] (AMQ-3948) Multiple consumers retrieving same message from ActiveMQ

Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/jira/browse/AMQ-3948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13425200#comment-13425200 ] 

Timothy Bish commented on AMQ-3948:
-----------------------------------

You can attach any info you have, however without a unit test showing your use-case and the problem being seen it will be hard for anyone to go much further on this.
                
> Multiple consumers retrieving same message from ActiveMQ
> --------------------------------------------------------
>
>                 Key: AMQ-3948
>                 URL: https://issues.apache.org/jira/browse/AMQ-3948
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.4.3
>         Environment: ActiveMQ 5.4.3 running on 64-bit Windows 7 OS. 64-bit JDK. 
>            Reporter: Joe Roberts
>             Fix For: NEEDS_REVIEWED
>
>         Attachments: applicationContext-mcp-parallelization-activemq.xml
>
>
> We have a java web-service (running in Jetty) that dynamically instantiates an ActiveMQ queue and send messages to the queue - the messages are integers (i.e. 1, 2, 3, etc). We have from one to many consumers that read from this queue to process these messages. Each consumer is started from a single process but each consumer is running in it's own thread or process. When we have multiple consumers running, they occasionally will pick up the same integer or message from the queue. This is not desired. If a consumer reads a message, we don't want other consumers to retrieve that same message. We're fairly new to ActiveMQ but those we're telling about this issue said it should not be happening. They think it might be that we have an ActiveMQ configuration issue. Could be we need to set a property to prevent this. Just looking for some help. I've attached our applicationContext-mcp-parallelization-activemq XML. We could have configured this incorrectly. We're using the internalAmqConnectionFactory for this queue.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

       

[jira] [Commented] (AMQ-3948) Multiple consumers retrieving same message from ActiveMQ

Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/jira/browse/AMQ-3948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13423860#comment-13423860 ] 

Timothy Bish commented on AMQ-3948:
-----------------------------------

Messages can be redelivered if your client fails to ACK them.  Can you provide a unit test that shows your issue?  Since you are on an old release its a good idea to give the latest release a try as well to see if your issue has been addressed. 
                
> Multiple consumers retrieving same message from ActiveMQ
> --------------------------------------------------------
>
>                 Key: AMQ-3948
>                 URL: https://issues.apache.org/jira/browse/AMQ-3948
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.4.3
>         Environment: ActiveMQ 5.4.3 running on 64-bit Windows 7 OS. 64-bit JDK. 
>            Reporter: Joe Roberts
>             Fix For: NEEDS_REVIEWED
>
>         Attachments: applicationContext-mcp-parallelization-activemq.xml
>
>
> We have a java web-service (running in Jetty) that dynamically instantiates an ActiveMQ queue and send messages to the queue - the messages are integers (i.e. 1, 2, 3, etc). We have from one to many consumers that read from this queue to process these messages. Each consumer is started from a single process but each consumer is running in it's own thread or process. When we have multiple consumers running, they occasionally will pick up the same integer or message from the queue. This is not desired. If a consumer reads a message, we don't want other consumers to retrieve that same message. We're fairly new to ActiveMQ but those we're telling about this issue said it should not be happening. They think it might be that we have an ActiveMQ configuration issue. Could be we need to set a property to prevent this. Just looking for some help. I've attached our applicationContext-mcp-parallelization-activemq XML. We could have configured this incorrectly. We're using the internalAmqConnectionFactory for this queue.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

       

[jira] [Updated] (AMQ-3948) Multiple consumers retrieving same message from ActiveMQ

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

Joe Roberts updated AMQ-3948:
-----------------------------

    Attachment: applicationContext-mcp-parallelization-activemq.xml
    
> Multiple consumers retrieving same message from ActiveMQ
> --------------------------------------------------------
>
>                 Key: AMQ-3948
>                 URL: https://issues.apache.org/jira/browse/AMQ-3948
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.4.3
>         Environment: ActiveMQ 5.4.3 running on 64-bit Windows 7 OS. 64-bit JDK. 
>            Reporter: Joe Roberts
>             Fix For: NEEDS_REVIEWED
>
>         Attachments: applicationContext-mcp-parallelization-activemq.xml
>
>
> We have a java web-service (running in Jetty) that dynamically instantiates an ActiveMQ queue and send messages to the queue - the messages are integers (i.e. 1, 2, 3, etc). We have from one to many consumers that read from this queue to process these messages. Each consumer is started from a single process but each consumer is running in it's own thread or process. When we have multiple consumers running, they occasionally will pick up the same integer or message from the queue. This is not desired. If a consumer reads a message, we don't want other consumers to retrieve that same message. We're fairly new to ActiveMQ but those we're telling about this issue said it should not be happening. They think it might be that we have an ActiveMQ configuration issue. Could be we need to set a property to prevent this. Just looking for some help. I've attached our applicationContext-mcp-parallelization-activemq XML. We could have configured this incorrectly. We're using the internalAmqConnectionFactory for this queue.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

       

[jira] [Resolved] (AMQ-3948) Multiple consumers retrieving same message from ActiveMQ

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

Joe Roberts resolved AMQ-3948.
------------------------------

    Resolution: Not A Problem

Problem found in our application, not ActiveMQ.
                
> Multiple consumers retrieving same message from ActiveMQ
> --------------------------------------------------------
>
>                 Key: AMQ-3948
>                 URL: https://issues.apache.org/jira/browse/AMQ-3948
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.4.3
>         Environment: ActiveMQ 5.4.3 running on 64-bit Windows 7 OS. 64-bit JDK. 
>            Reporter: Joe Roberts
>             Fix For: NEEDS_REVIEWED
>
>         Attachments: applicationContext-mcp-parallelization-activemq.xml
>
>
> We have a java web-service (running in Jetty) that dynamically instantiates an ActiveMQ queue and send messages to the queue - the messages are integers (i.e. 1, 2, 3, etc). We have from one to many consumers that read from this queue to process these messages. Each consumer is started from a single process but each consumer is running in it's own thread or process. When we have multiple consumers running, they occasionally will pick up the same integer or message from the queue. This is not desired. If a consumer reads a message, we don't want other consumers to retrieve that same message. We're fairly new to ActiveMQ but those we're telling about this issue said it should not be happening. They think it might be that we have an ActiveMQ configuration issue. Could be we need to set a property to prevent this. Just looking for some help. I've attached our applicationContext-mcp-parallelization-activemq XML. We could have configured this incorrectly. We're using the internalAmqConnectionFactory for this queue.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

       

[jira] [Commented] (AMQ-3948) Multiple consumers retrieving same message from ActiveMQ

Posted by "Joe Roberts (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/jira/browse/AMQ-3948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13424872#comment-13424872 ] 

Joe Roberts commented on AMQ-3948:
----------------------------------

I have tried using ActiveMQ 5.6 and the same issue is seen there. This typically happens when multiple consumers attempt to retrieve a message at the same time. Our consumers spit out logs and the logged messages occur within the same second. If the timing is outside of that, this issue is not seen and messages are retrieved normally. If our client was failing to do something, I would expect this redelivery to occur all the time. The timing on this also makes it difficult to lock down in a unit test, though we can try. Would our logs or the activemq logs be helpful here?
                
> Multiple consumers retrieving same message from ActiveMQ
> --------------------------------------------------------
>
>                 Key: AMQ-3948
>                 URL: https://issues.apache.org/jira/browse/AMQ-3948
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.4.3
>         Environment: ActiveMQ 5.4.3 running on 64-bit Windows 7 OS. 64-bit JDK. 
>            Reporter: Joe Roberts
>             Fix For: NEEDS_REVIEWED
>
>         Attachments: applicationContext-mcp-parallelization-activemq.xml
>
>
> We have a java web-service (running in Jetty) that dynamically instantiates an ActiveMQ queue and send messages to the queue - the messages are integers (i.e. 1, 2, 3, etc). We have from one to many consumers that read from this queue to process these messages. Each consumer is started from a single process but each consumer is running in it's own thread or process. When we have multiple consumers running, they occasionally will pick up the same integer or message from the queue. This is not desired. If a consumer reads a message, we don't want other consumers to retrieve that same message. We're fairly new to ActiveMQ but those we're telling about this issue said it should not be happening. They think it might be that we have an ActiveMQ configuration issue. Could be we need to set a property to prevent this. Just looking for some help. I've attached our applicationContext-mcp-parallelization-activemq XML. We could have configured this incorrectly. We're using the internalAmqConnectionFactory for this queue.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

       

[jira] [Commented] (AMQ-3948) Multiple consumers retrieving same message from ActiveMQ

Posted by "Joe Roberts (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/jira/browse/AMQ-3948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13440609#comment-13440609 ] 

Joe Roberts commented on AMQ-3948:
----------------------------------

Thanks Timothy. No need to go any further anyway. We couldn't reproduce the problem with a j-unit - activemq worked fine in that scenario. So we looked elsewhere for the issue and found it to be something internal to our application. We've fixed that - works fine now. Resolving.
                
> Multiple consumers retrieving same message from ActiveMQ
> --------------------------------------------------------
>
>                 Key: AMQ-3948
>                 URL: https://issues.apache.org/jira/browse/AMQ-3948
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.4.3
>         Environment: ActiveMQ 5.4.3 running on 64-bit Windows 7 OS. 64-bit JDK. 
>            Reporter: Joe Roberts
>             Fix For: NEEDS_REVIEWED
>
>         Attachments: applicationContext-mcp-parallelization-activemq.xml
>
>
> We have a java web-service (running in Jetty) that dynamically instantiates an ActiveMQ queue and send messages to the queue - the messages are integers (i.e. 1, 2, 3, etc). We have from one to many consumers that read from this queue to process these messages. Each consumer is started from a single process but each consumer is running in it's own thread or process. When we have multiple consumers running, they occasionally will pick up the same integer or message from the queue. This is not desired. If a consumer reads a message, we don't want other consumers to retrieve that same message. We're fairly new to ActiveMQ but those we're telling about this issue said it should not be happening. They think it might be that we have an ActiveMQ configuration issue. Could be we need to set a property to prevent this. Just looking for some help. I've attached our applicationContext-mcp-parallelization-activemq XML. We could have configured this incorrectly. We're using the internalAmqConnectionFactory for this queue.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira