Return-Path: X-Original-To: apmail-activemq-users-archive@www.apache.org Delivered-To: apmail-activemq-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id E483910BA9 for ; Tue, 30 Apr 2013 14:42:05 +0000 (UTC) Received: (qmail 12757 invoked by uid 500); 30 Apr 2013 14:42:05 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 12655 invoked by uid 500); 30 Apr 2013 14:42:05 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 12643 invoked by uid 99); 30 Apr 2013 14:42:04 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 30 Apr 2013 14:42:04 +0000 X-ASF-Spam-Status: No, hits=2.8 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,URI_HEX X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of christian.posta@gmail.com designates 209.85.217.176 as permitted sender) Received: from [209.85.217.176] (HELO mail-lb0-f176.google.com) (209.85.217.176) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 30 Apr 2013 14:42:00 +0000 Received: by mail-lb0-f176.google.com with SMTP id p10so572180lbv.7 for ; Tue, 30 Apr 2013 07:41:39 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:x-received:in-reply-to:references:date:message-id :subject:from:to:content-type; bh=ceCQWq/iMjSS/MgRqMYofg2P+tp8Sf8lUSlJQjRNI2o=; b=M8AkQByMnWnqZiM3K5abgzBDgF5nNfw/7Lpz6rthW9us+2mqTOI1P8xsqNqXCDjK2T LqWJNfrVhbw4NbQE2/q9IWLHCzO0VkKGns/PYqkcKIWaR7/weqbLVEsO6QjwFKa+5G30 9lnGFBgrIBj0igBu1xQ5+m8aPCx8kf/sG83kSgPGDhTjedG1jO3898vDkCHm2bd26fLt d37etsCxu69oA2KwXcDkoJUic8pL71Vn48t2NVVy2g1DeIyzBMiES6LLDF/zL7kswltE NBBqgnqePGUin2yRgeEUifpJVjOovvmxuLvY2pxEYns0skNUJ/Nok/3Tm25SvRf+/K4a o/uw== MIME-Version: 1.0 X-Received: by 10.152.87.116 with SMTP id w20mr19631547laz.0.1367332890599; Tue, 30 Apr 2013 07:41:30 -0700 (PDT) Received: by 10.114.96.194 with HTTP; Tue, 30 Apr 2013 07:41:30 -0700 (PDT) In-Reply-To: <1367314963256-4666444.post@n4.nabble.com> References: <1366999937865-4666277.post@n4.nabble.com> <1367055856989-4666305.post@n4.nabble.com> <1367258922594-4666406.post@n4.nabble.com> <1367314963256-4666444.post@n4.nabble.com> Date: Tue, 30 Apr 2013 07:41:30 -0700 Message-ID: Subject: Re: Query around ActiveMQ.DLQ From: Christian Posta To: "users@activemq.apache.org" Content-Type: multipart/alternative; boundary=001a11c237c43be82304db94ffb3 X-Virus-Checked: Checked by ClamAV on apache.org --001a11c237c43be82304db94ffb3 Content-Type: text/plain; charset=ISO-8859-1 Inline... On Tue, Apr 30, 2013 at 2:42 AM, marnold wrote: > Thanks Christian. > > (I work with Deepak.) > > In our system, Camel produces JMS messages from integrated endpoints, which > are consumed by EJB MDBs. The EJB application produces new JMS messages, > which are consumed by Camel to send to other integrated endpoints (eg. > WebSphere MQ). We use transacted routes, and Atomikos as XA transaction > coordinator. ActiveMQ 5.6.0, Camel 2.9.0. > So if you're communicating with the broker using transactions, everything except the commit/rollback will be sent asynchronous. This could lead to blocking the entire connection on producer flow control. Try setting the producer window on your connections as described in http://activemq.apache.org/producer-flow-control.html > > Our Camel process has a single Spring bean for the ActiveMQ broker > (org.apache.activemq.camel.component.ActiveMQComponent), so I assume this > means it both consumes and produces on the same connection? > Mmmm.. depends on how you configured your connection factory... are you pooling connections? > > In the Camel documentation, I can see that JMS property asyncConsumer is > default 'false'. But there does not seem to be a property 'asyncProducer'? > Well... I think those properties are more for how the endpoint treats the exchange with regard to ordering and async processing > > Would the best way to resolve this - in our case - to ensure Camel is a > synchronous producer, or to ensure Camel uses one connection to produce > messages and a different connection to consume messages? > > Try setting the producer window on your connection so that PFC doesn't block the entire connection. > Thanks in advance. > > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Query-around-ActiveMQ-DLQ-tp4666277p4666444.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta --001a11c237c43be82304db94ffb3--