From users-return-21366-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Fri Nov 13 16:54:59 2009 Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 43301 invoked from network); 13 Nov 2009 16:54:59 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 13 Nov 2009 16:54:59 -0000 Received: (qmail 61278 invoked by uid 500); 13 Nov 2009 16:54:58 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 61249 invoked by uid 500); 13 Nov 2009 16:54:58 -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 61239 invoked by uid 99); 13 Nov 2009 16:54:58 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 13 Nov 2009 16:54:58 +0000 X-ASF-Spam-Status: No, hits=-2.5 required=5.0 tests=AWL,BAYES_00,HTML_MESSAGE X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of chubrilo@gmail.com designates 209.85.218.215 as permitted sender) Received: from [209.85.218.215] (HELO mail-bw0-f215.google.com) (209.85.218.215) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 13 Nov 2009 16:54:55 +0000 Received: by bwz7 with SMTP id 7so3887059bwz.6 for ; Fri, 13 Nov 2009 08:54:34 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:sender:received:in-reply-to :references:date:x-google-sender-auth:message-id:subject:from:to :content-type; bh=v9IBF7rbM5RNY5VyKr45ti0iprOMIRzH+1sVrlwW0R0=; b=Sv+1Q4bxyNGTWbeY1rZrxc3Bb0OsoMu7cxe7WxDgaL+/pTHKrDbgnuRaJIigsoeZ6Y RrSQIvofN9kWhzzxR7t/cHu1H7pR5BWdJqR39iZJM384wjsV39qUXORnAgYT58BleuaM yUSluV/qQ7EJDdKtmb/dOJXxFcfcOO7jnqSjs= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:sender:in-reply-to:references:date :x-google-sender-auth:message-id:subject:from:to:content-type; b=sCFMA66pzXTBka2FzJsQXwIH1Thg1ZuuHVt1FgEr1i7ruitPQsUbLvuv1U5pkKkIt5 cmwt5GKF0SKoJ0oZ77g9UFkzXo0t/7szh+gSj9v08XoXZFaVBaSqNHBlrq8SCzTe3yCv 7Tpn1iOCK9B1zIbOO3UYcD/WMUA4NLehcn21k= MIME-Version: 1.0 Sender: chubrilo@gmail.com Received: by 10.223.14.145 with SMTP id g17mr687434faa.51.1258131273765; Fri, 13 Nov 2009 08:54:33 -0800 (PST) In-Reply-To: <26339683.post@talk.nabble.com> References: <26308746.post@talk.nabble.com> <36e91d9d0911120101q7ca96ad7xa4d8fec11d3a6f71@mail.gmail.com> <26321438.post@talk.nabble.com> <44cb1ba30911121429ue8fe9b2i34401e70a3ca8ba6@mail.gmail.com> <26339683.post@talk.nabble.com> Date: Fri, 13 Nov 2009 17:54:33 +0100 X-Google-Sender-Auth: 5c363fbd1237eae2 Message-ID: <36e91d9d0911130854o3608041bw60bbfd0eae1ef0cf@mail.gmail.com> Subject: Re: hasFrameToRead always returns false after first message From: Dejan Bosanac To: users@activemq.apache.org Content-Type: multipart/alternative; boundary=00151747360aa752b104784383c0 --00151747360aa752b104784383c0 Content-Type: text/plain; charset=ISO-8859-1 Hi, checkout here: http://issues.apache.org/activemq/browse/AMQ-1874 Cheers -- Dejan Bosanac - http://twitter.com/dejanb Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Fri, Nov 13, 2009 at 5:51 PM, jwotman wrote: > > Thanks Roger. My original issue was that I hadn't explicitly set the > prefetch size. I don't have to worry about the nack issue > because,eventually, every message does get acknowledged (if it fails after > retries, it'll be acknowledged and notifications sent out). My main issue > now is that I don't see a way through STOMP to set my session in > INDIVIDUAL_ACKNOWLEDGE mode. If I ack a message out of order, then the > messages read before it in the queue will also be acknowledged. The > individual_acknowledge mode is not part of the JMS spec and, in Java, I > need > to explicitly use activemq classes to set that. In the possible headers > when establishing a connection with STOMP, I don't see a way to do that. > Anybody know if there's an undocumented way to set a header with STOMP > that'll allow for use of INDIVIDUAL_ACKNOWLEDGE > > > > Roger Hoover wrote: > > > > I don't know about the PHP stomp client that you're using but the STOMP > > protocol and AMQ broker support what you want. I wrote a twisted python > > STOMP client that can concurrently process stomp messages and ack them in > > any order. > > > > A potential issue with the approach you've described is that STOMP has no > > way to for a client to reject a message. There's no nack operation. So > > if > > your client experiences an error trying to process a message and does not > > ack that message, you've effectively just reduced your > > activemq.prefetchSize > > by 1. Eventually, you'll hit zero and no longer get messages from the > > broker. The only option is to unsubscribe and subscribe again. > > > > Roger > > > > On Thu, Nov 12, 2009 at 1:20 PM, jwotman wrote: > > > >> > >> OK. I see now that the stomp client does not allow reading of next > >> message > >> until the message already read has been acknowledged. This does not > >> match > >> with what we need. Ideally, we'd like to "browse" the queue with Stomp > >> and > >> then acknowledge messages out of order when and if the operation > >> connected > >> with the message succeeds as part of a separate STOMP session. Messages > >> are > >> being sent with INDIVIDUAL_ACKNOWLEDGE. As a less desirable solution, > >> we've implemented a message feed, using a servlet and then the php > >> application can acknowledge any message when it needs. > >> > >> Is there another way to do this purely using STOMP? > >> > >> > >> > >> > >> Hi Dejan: > >> > >> Thanks for the correction. However, I'm getting the same result. > >> -- > >> View this message in context: > >> > http://old.nabble.com/hasFrameToRead-always-returns-false-after-first-message-tp26308746p26326633.html > >> Sent from the ActiveMQ - User mailing list archive at Nabble.com. > >> > >> > > > > > > -- > View this message in context: > http://old.nabble.com/hasFrameToRead-always-returns-false-after-first-message-tp26308746p26339683.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > > --00151747360aa752b104784383c0--