Return-Path: 
 <activemq-users-return-3318-apmail-geronimo-activemq-users-archive=geronimo.apache.org@geronimo.apache.org>
Delivered-To: apmail-geronimo-activemq-users-archive@www.apache.org
Received: (qmail 58093 invoked from network); 1 Aug 2006 13:42:18 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199)
  by minotaur.apache.org with SMTP; 1 Aug 2006 13:42:18 -0000
Received: (qmail 23240 invoked by uid 500); 1 Aug 2006 13:42:15 -0000
Delivered-To: apmail-geronimo-activemq-users-archive@geronimo.apache.org
Received: (qmail 23223 invoked by uid 500); 1 Aug 2006 13:42:15 -0000
Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:activemq-users-help@geronimo.apache.org>
List-Unsubscribe: <mailto:activemq-users-unsubscribe@geronimo.apache.org>
List-Post: <mailto:activemq-users@geronimo.apache.org>
List-Id: <activemq-users.geronimo.apache.org>
Reply-To: activemq-users@geronimo.apache.org
Delivered-To: mailing list activemq-users@geronimo.apache.org
Received: (qmail 23207 invoked by uid 99); 1 Aug 2006 13:42:15 -0000
Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 01 Aug 2006 06:42:15 -0700
X-ASF-Spam-Status: No, hits=0.5 required=10.0
	tests=DNS_FROM_RFC_ABUSE,SPF_PASS
X-Spam-Check-By: apache.org
Received-SPF: pass (asf.osuosl.org: domain of james.strachan@gmail.com
 designates 66.249.82.207 as permitted sender)
Received: from [66.249.82.207] (HELO wx-out-0102.google.com) (66.249.82.207)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 01 Aug 2006 06:42:12 -0700
Received: by wx-out-0102.google.com with SMTP id s13so504570wxc
        for <activemq-users@geronimo.apache.org>;
 Tue, 01 Aug 2006 06:41:51 -0700 (PDT)
DomainKey-Signature: a=rsa-sha1; q=dns; c=nofws;
        s=beta; d=gmail.com;
        h=received:message-id:date:from:to:subject:in-reply-to:mime-version:content-type:content-transfer-encoding:content-disposition:references;
        b=Y6k/cL9W7yiv21w8R7gmwTxskRD84D/PPX7dfBFEhv2oWvNxC6yuU6mXyoWffR8TdXksU7avAswouuXXJ7yjb1jhCO8JNaMtYMClVCu1sAzhCA0PTzH3a92flCy4zaubZnk5EKbiAxHfdTpmRR9HLyEqSPbRxQZqGOJWekINxlA=
Received: by 10.78.147.3 with SMTP id u3mr280064hud;
        Tue, 01 Aug 2006 06:41:51 -0700 (PDT)
Received: by 10.78.174.8 with HTTP; Tue, 1 Aug 2006 06:41:51 -0700 (PDT)
Message-ID: <ec6e67fd0608010641h3d446095xba04e2c34c6c7cb3@mail.gmail.com>
Date: Tue, 1 Aug 2006 14:41:51 +0100
From: "James Strachan" <james.strachan@gmail.com>
To: activemq-users@geronimo.apache.org, sandeep@wssource.com
Subject: Re: Stomp - message woes - Ruby client
In-Reply-To: <1154439344.4816.8.camel@dhcp-prv-165.int.wssource.com>
MIME-Version: 1.0
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: 7bit
Content-Disposition: inline
References: <1154439344.4816.8.camel@dhcp-prv-165.int.wssource.com>
X-Virus-Checked: Checked by ClamAV on apache.org
X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N

If you look in JMX do you see just a single consumer?

http://incubator.apache.org/activemq/jmx.html

On 8/1/06, Sandeep Chayapathi <sandeep@wssource.com> wrote:
> Hi all,
>
>  This is a followup to my earlier mail regarding Stomp and the perl
> client. I have a simple producer and consumer, using ruby client. Im
> using AMQ 4.0.1.
>
>  The problem is, every other message is missed by the consumer.
> Moreover, after a message has been consumed, it is not being removed
> from the queue.
>
>  Im not able to figure out what the issue is. Any help is greatly
> appreciated. Thanks in advance.
>
> Here is the destination policy being used:
>
> ---- activemq.xml ----
>     <destinationPolicy>
>       <policyMap><policyEntries>
>
>           <policyEntry topic="FOO.>">
>             <dispatchPolicy>
>               <strictOrderDispatchPolicy />
>             </dispatchPolicy>
>             <subscriptionRecoveryPolicy>
>               <lastImageSubscriptionRecoveryPolicy />
>             </subscriptionRecoveryPolicy>
>           </policyEntry>
>
>       </policyEntries></policyMap>
>     </destinationPolicy>
> -----------------------
>
>
>  Here is the code:
>
> ---- read.rb ------
> #!/usr/bin/env ruby
> require 'stomp'
>
> client = Stomp::Connection.new("test","user")
>
> client.subscribe "/queue/FOO.test"
>
> while TRUE
>     puts "sleeping"
>     sleep 0.01
>     msg = client.receive
>     puts msg.body
> end
> --------------------
>
>
> ---- write.rb ------
> #!/usr/bin/env ruby
> require 'stomp'
>
> client = Stomp::Connection.new("test","user")
>
> client.subscribe "/queue/FOO.test"
>
>
>
> for i in 0..10
>     sleep 1
>     client.send "/queue/FOO.test", "[Ruby] message " + i.to_s
>     puts "[Ruby] message " + i.to_s
> end
>
> client.disconnect
> ---------------------
>
>


-- 

James
-------
http://radio.weblogs.com/0112098/