activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From PankajGugnani <pankaj_iceb...@yahoo.co.in>
Subject Re: how to best implement a producer timeout
Date Thu, 11 Dec 2008 06:34:12 GMT

Hi rajdavies,

Thanks for the quick reply.
In my project, I want to throw an exception if timeout occured. But for
this, I need to know what happened to the message. Is it published or is it
discarded. And also, is there way by which I can get an acknowledgement of
what happend to the message(like added to the queue or discarded)

rajdavies wrote:
> 
> 
> On 11 Dec 2008, at 06:08, PankajGugnani wrote:
> 
>>
>> Hi,
>>
>> can u please explain the behaviou in this particular case after the  
>> TimeOut.
>> will there be an exception thrown if the timeout occurs.
>>
>> Thanks in advance
>>
>> rajdavies wrote:
> 
> Not currently - I'm afraid there's no difference between a successful  
> send and a request that timed out - perhaps someone should raise a  
> jira for that one ?
>>
>>>
>>>
>>> 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/
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>
>> -- 
>> View this message in context:
>> http://www.nabble.com/how-to-best-implement-a-producer-timeout-tp20947923p20949967.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
> 
> 
> 

-- 
View this message in context: http://www.nabble.com/how-to-best-implement-a-producer-timeout-tp20947923p20950155.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message