Return-Path: 
 <users-return-15954-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: (qmail 53908 invoked from network); 11 Sep 2008 12:31:57 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2)
  by minotaur.apache.org with SMTP; 11 Sep 2008 12:31:57 -0000
Received: (qmail 94424 invoked by uid 500); 11 Sep 2008 12:31:53 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 94405 invoked by uid 500); 11 Sep 2008 12:31:53 -0000
Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@activemq.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@activemq.apache.org>
List-Post: <mailto:users@activemq.apache.org>
List-Id: <users.activemq.apache.org>
Reply-To: users@activemq.apache.org
Delivered-To: mailing list users@activemq.apache.org
Received: (qmail 94394 invoked by uid 99); 11 Sep 2008 12:31:52 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 11 Sep 2008 05:31:52 -0700
X-ASF-Spam-Status: No, hits=3.2 required=10.0
	tests=HTML_MESSAGE,SPF_HELO_PASS,SPF_NEUTRAL
X-Spam-Check-By: apache.org
Received-SPF: neutral (athena.apache.org: local policy)
Received: from [194.247.192.231] (HELO EUnet.yu) (194.247.192.231)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 11 Sep 2008 12:30:52 +0000
Received: from [194.247.199.205] (billingdev-hotspot.eunet.co.yu
 [194.247.199.205] (may be forged))
	by EUnet.yu (8.13.6/8.13.6) with ESMTP id m8BCUuYF021797
	for <users@activemq.apache.org>; Thu, 11 Sep 2008 14:30:57 +0200
Message-ID: <48C90F80.6000907@ttmsolutions.com>
Date: Thu, 11 Sep 2008 14:30:56 +0200
From: Dejan Bosanac <dejan.bosanac@ttmsolutions.com>
User-Agent: Thunderbird 2.0.0.16 (X11/20080724)
MIME-Version: 1.0
To: users@activemq.apache.org
Subject: Re: Multiple Consumers with REST
References: <19374412.post@talk.nabble.com>
 <48C67C44.3000705@ttmsolutions.com> <19402730.post@talk.nabble.com>
In-Reply-To: <19402730.post@talk.nabble.com>
Content-Type: multipart/alternative;
 boundary="------------010604060102090502040607"
X-EUNET-AVAS-Milter-Version: 2.0.0
X-AVAS-Virus-Status: clean
X-AVAS-Virus-Status: clean
X-AVAS-Spamd-Symbols: BAYES_50,HTML_30_40,HTML_MESSAGE,UNPARSEABLE_RELAY
X-AVAS-Spam-Score: 0.4
X-AVAS-Spam-Level: x
X-Virus-Checked: Checked by ClamAV on apache.org

--------------010604060102090502040607
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 7bit

Hi,

I've just tested and setting the message servler like this

    <servlet>
        <servlet-name>MessageServlet</servlet-name>
       
<servlet-class>org.apache.activemq.web.MessageServlet</servlet-class>
        <load-on-startup>1</load-on-startup>
        <init-param>
                <param-name>destinationOptions</param-name>
                <param-value>consumer.prefetchSize=1</param-value>
        </init-param>
    </servlet>

in webapps/demo/WEB-INF/web.xml

should make a pretty even distribution of messages between clients.

As for explicit unsubscribing of REST consumers, I've made a JIRA
enhacement request for that
https://issues.apache.org/activemq/browse/AMQ-1933

Cheers

-- 
Dejan Bosanac


http://www.ttmsolutions.com - get a free ActiveMQ user guide

ActiveMQ in Action - http://www.manning.com/snyder/
Scripting in Java - http://www.scriptinginjava.net



yesnid wrote:
> Thank you for the help Dejan, I tried preset to one and I still have an
> issue. If run each consumer and use the same JSESSIONID then they can all
> consume, however If I have each one acquire a JSESSIONID, then they hang. I
> think it has to do with closing this session. Is there a way to explicitly
> close this as a client? Also is there a way to configure the time out for
> this?
>
> Thank you,
>  
>
> Dejan Bosanac-3 wrote:
>   
>> I think this could be a "prefetch size issue" meaning that all your
>> messages are being sent to the first consumer. Try setting, prefetch
>> size for you connection between rest servlet and broker
>>
>> http://activemq.apache.org/what-is-the-prefetch-limit-for.html
>>
>> Cheers
>>
>> -- 
>> Dejan Bosanac
>>
>>
>> http://www.ttmsolutions.com - get a free ActiveMQ user guide
>>
>> ActiveMQ in Action - http://www.manning.com/snyder/
>> Scripting in Java - http://www.scriptinginjava.net
>>
>>
>>
>> yesnid wrote:
>>     
>>> Hello All,
>>>
>>> I am trying to have two consumers recieve messages from the same queue
>>> using
>>> the rest interface to the ActiveMQ Broker, and am having issues where
>>> only
>>> one of them can recieve messages at a time. The other consumer simply
>>> times
>>> out indicating there are no messages in the queue even though I have
>>> verified that there are. Am I doing something wrong?
>>>
>>> Thank you.
>>>   
>>>       
>>
>>
>>     
>
>   



--------------010604060102090502040607--