Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of rajdavies@gmail.com
 designates 209.85.221.12 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=message-id:from:to:in-reply-to:content-type
         :content-transfer-encoding:mime-version:subject:date:references
         :x-mailer;
        b=USZOxPz5tJLCsuibWRcxcATrkUlsK+rlUC0hVVwHrARAWGTOWD9QB8H/gpLQA65LAX
         mFZlC4zV5AulnCtCQqD68HZrDHRsul6rDlhiBc7o503Ltx4wu9ztRtXSHUrENK/QBlUX
         6gMUZt0T76LDeTxBaGgI4UZ9MuPfb0k3tKftI=
Message-Id: <BDD25175-3BFF-42ED-BEA5-02581CA77A99@gmail.com>
From: Rob Davies <rajdavies@gmail.com>
To: users@activemq.apache.org
In-Reply-To: <20947923.post@talk.nabble.com>
Content-Type: text/plain; charset=US-ASCII; format=flowed; delsp=yes
Content-Transfer-Encoding: 7bit
Mime-Version: 1.0 (Apple Message framework v929.2)
Subject: Re: how to best implement a producer timeout
Date: Thu, 11 Dec 2008 06:05:21 +0000
References: <20947923.post@talk.nabble.com>


On 11 Dec 2008, at 01:38, emc2family wrote:

>
> Hi,
>
> when a broker starts to block producers as a result of producer flow
> control, is there an elegant way for a producer to timeout as a  
> result of
> this?  i was thinking of setting the message's timetolive to achieve  
> this.
> i suppose i could also use maxinactivityduration.  i think both will  
> throw a
> jmsexception.  which leads me to my next question.  is there a  
> specific
> error code for a timetolive or maxinactivityduration exceptions?   
> thanks a
> bunch.
> -- 
> View this message in context: http://www.nabble.com/how-to-best-implement-a-producer-timeout-tp20947923p20947923.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Not elegant - but one of these - if you are sending with default  
delivery mode (PERSISTENT):

When you create your MessageProducer - cast it to an  
org.apache.activemq.ActiveMQMessageProducer and set it via the  
setSendTimeout(int ) method
or


set the sendTimeout property on the ActiveMQConnection

or set the sendTimeout on the ActiveMQConnectionFactory - either  
directly or via a property

or my favourite:

Set the sendTimeout as a property on the destination used to create  
the producer - e.g. if you want to send on a Topic called "foo" - call

Destination dest= session.createTopic("foo?producer.sendTimeout="5000");
MessageProducer producer = session.createProducer(dest);


cheers,

Rob

Rob Davies
http://fusesource.com
http://rajdavies.blogspot.com/