Return-Path: X-Original-To: apmail-activemq-dev-archive@www.apache.org Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 0420387A7 for ; Wed, 24 Aug 2011 15:46:53 +0000 (UTC) Received: (qmail 92777 invoked by uid 500); 24 Aug 2011 15:46:52 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 92680 invoked by uid 500); 24 Aug 2011 15:46:51 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 92666 invoked by uid 99); 24 Aug 2011 15:46:51 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 24 Aug 2011 15:46:51 +0000 X-ASF-Spam-Status: No, hits=-2000.5 required=5.0 tests=ALL_TRUSTED,RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.116] (HELO hel.zones.apache.org) (140.211.11.116) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 24 Aug 2011 15:46:49 +0000 Received: from hel.zones.apache.org (hel.zones.apache.org [140.211.11.116]) by hel.zones.apache.org (Postfix) with ESMTP id 785BFCDA36 for ; Wed, 24 Aug 2011 15:46:29 +0000 (UTC) Date: Wed, 24 Aug 2011 15:46:29 +0000 (UTC) From: "Fengming Lou (JIRA)" To: dev@activemq.apache.org Message-ID: <784031223.9625.1314200789489.JavaMail.tomcat@hel.zones.apache.org> Subject: [jira] [Commented] (AMQ-1853) Optional non-blocking redelivery MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/AMQ-1853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13090303#comment-13090303 ] Fengming Lou commented on AMQ-1853: ----------------------------------- Since a message goes to dead letter queue once maximumRedeliveries is exceeded. One "work around" is to take advantage of individualDeadLetterStrategy. By shortening the maximuRedelieveries with the following configuration, the message will go back to the original queue and not to block new messages. > Optional non-blocking redelivery > -------------------------------- > > Key: AMQ-1853 > URL: https://issues.apache.org/jira/browse/AMQ-1853 > Project: ActiveMQ > Issue Type: Wish > Components: Broker > Affects Versions: 5.1.0 > Reporter: Demian Mrakovich > Fix For: 5.6.0 > > > When a message is redelivered the consumer blocks for the amount of time specified by the redelivery delay. For a high load scenario where message order is irrelevant this is just reducing performance and will result in a complete halt if the delay is long and several bad messages are consumed in a short time. > I think what I basically wish for is how it worked in versions 3.x, prior to fix for AMQ-268. So I would very much like to have configurable option to NOT block consumers when redelivering messages. > If no-one feels up to it, I'd still appreciate some hints and I could try to fix it myself. Looking at ActiveMQMessageConsumer.rollback(), I was thinking something in the lines of just scheduling a task to put the message back on queue after a delay - if configured to, instead of stopping delivery and a schedule a task to resume delivery again. But I do not possess an understanding of AMQ thorough enough to predict potential side effects of this, so any analysis would be helpful. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira