From users-return-29235-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Tue Nov 8 12:16:26 2011 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 9A8199C63 for ; Tue, 8 Nov 2011 12:16:26 +0000 (UTC) Received: (qmail 3589 invoked by uid 500); 8 Nov 2011 12:16:26 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 3558 invoked by uid 500); 8 Nov 2011 12:16:26 -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 3550 invoked by uid 99); 8 Nov 2011 12:16:26 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 08 Nov 2011 12:16:26 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: local policy) Received: from [216.32.181.185] (HELO ch1outboundpool.messaging.microsoft.com) (216.32.181.185) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 08 Nov 2011 12:16:16 +0000 Received: from mail85-ch1-R.bigfish.com (10.43.68.247) by CH1EHSOBE009.bigfish.com (10.43.70.59) with Microsoft SMTP Server id 14.1.225.22; Tue, 8 Nov 2011 12:15:32 +0000 Received: from mail85-ch1 (localhost.localdomain [127.0.0.1]) by mail85-ch1-R.bigfish.com (Postfix) with ESMTP id 8CD0710E0240 for ; Tue, 8 Nov 2011 12:15:45 +0000 (UTC) X-SpamScore: 0 X-BigFish: VPS0(zzc89bhc85dhzz1202hzz8275bh8275dhz2dh668h839h34h61h) X-Spam-TCS-SCL: 0:0 X-Forefront-Antispam-Report: CIP:74.205.227.224;KIP:(null);UIP:(null);IPVD:NLI;H:crlexfe01.wallstreetsystems.com;RD:none;EFVD:NLI Received: from mail85-ch1 (localhost.localdomain [127.0.0.1]) by mail85-ch1 (MessageSwitch) id 132075454569349_6512; Tue, 8 Nov 2011 12:15:45 +0000 (UTC) Received: from CH1EHSMHS025.bigfish.com (snatpool1.int.messaging.microsoft.com [10.43.68.248]) by mail85-ch1.bigfish.com (Postfix) with ESMTP id 09938AF0050 for ; Tue, 8 Nov 2011 12:15:45 +0000 (UTC) Received: from crlexfe01.wallstreetsystems.com (74.205.227.224) by CH1EHSMHS025.bigfish.com (10.43.70.25) with Microsoft SMTP Server id 14.1.225.22; Tue, 8 Nov 2011 12:15:54 +0000 Received: from SOPEXMB01.eu.wallstreetsystems.com ([172.24.22.90]) by crlexfe01.wallstreetsystems.com with Microsoft SMTPSVC(6.0.3790.4675); Tue, 8 Nov 2011 07:15:52 -0500 X-MimeOLE: Produced By Microsoft Exchange V6.5 Content-Class: urn:content-classes:message MIME-Version: 1.0 Content-Type: multipart/mixed; boundary="----_=_NextPart_001_01CC9E10.27F8435C" Subject: ActiveMQCPP - Failover and prefetch=0 can result in hung consumers if the MessagePull command is lost Date: Tue, 8 Nov 2011 13:15:51 +0100 Message-ID: <7C1C8C76771DF84896D3B7557BECB28AB5FA77@SOPEXMB01.eu.wallstreetsystems.com> X-MS-Has-Attach: yes X-MS-TNEF-Correlator: Thread-Topic: ActiveMQCPP - Failover and prefetch=0 can result in hung consumers if the MessagePull command is lost Thread-Index: AcyeDNvoRqjWBrCVT5SSpqR01bfHTA== From: Daniel Laugt To: X-OriginalArrivalTime: 08 Nov 2011 12:15:52.0817 (UTC) FILETIME=[28CE3610:01CC9E10] X-OriginatorOrg: wallstreetsystems.com X-Virus-Checked: Checked by ClamAV on apache.org ------_=_NextPart_001_01CC9E10.27F8435C Content-Type: multipart/alternative; boundary="----_=_NextPart_002_01CC9E10.27F8435C" ------_=_NextPart_002_01CC9E10.27F8435C Content-Type: text/plain; charset="iso-8859-1" Content-Transfer-Encoding: quoted-printable Hello, =20 I'm using ActiveMQ 5.5.0 with ActiveMQ-CPP as client. With configuration = prefetch size =3D 0, polling consumer fails to reconnect during the = failover. =20 This issue has been fixed by the item AMQ-2877: https://issues.apache.org/jira/browse/AMQ-2877 =20 AMQ-2877 fixes the problem in the java client side but not in the c++ = client side. Is it possible to merge this fix to ActiveMQ-CPP? =20 Attached on this email a diff of what I've merged from AMQ-2877 to = resolve the problem on my ActiveMQ-CPP. This diff can be used probably = as a suggestion... =20 Regards, Daniel La=FCgt. =20 ------_=_NextPart_002_01CC9E10.27F8435C Content-Type: text/html; charset="iso-8859-1" Content-Transfer-Encoding: quoted-printable

Hello,

 

I’m = using ActiveMQ 5.5.0 with ActiveMQ-CPP as client. With configuration = prefetch size =3D 0, polling consumer fails to reconnect during the = failover.

 

This issue has been fixed by the item = AMQ-2877:

https://issues.ap= ache.org/jira/browse/AMQ-2877

 

AMQ-2877 = fixes the problem in the java client side but not in the c++ client = side. Is it possible to merge this fix to ActiveMQ-CPP?

 

Attached on = this email a diff of what I’ve merged from AMQ-2877 to resolve the = problem on my ActiveMQ-CPP. This diff can be used probably as a = suggestion…

 

Regards,

Daniel = La=FCgt.

 

------_=_NextPart_002_01CC9E10.27F8435C-- ------_=_NextPart_001_01CC9E10.27F8435C--