Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
MIME-Version: 1.0
In-Reply-To: <1459783098898-4710264.post@n4.nabble.com>
References: <1459783098898-4710264.post@n4.nabble.com>
From: Christopher Shannon <christopher.l.shannon@gmail.com>
Date: Mon, 4 Apr 2016 12:01:05 -0400
Message-ID: 
 <CACHnxzycLQ2t4ELU8H5dm=LVve2ac5wniq=Fzw_Y=wp+u9yOkA@mail.gmail.com>
Subject: Re: Force Producer to fail when blocked by slow consumer?
To: users@activemq.apache.org
Content-Type: multipart/alternative; boundary=001a114718c6d06b09052faad7ba

--001a114718c6d06b09052faad7ba
Content-Type: text/plain; charset=UTF-8

There are a couple options you can configure.  Take a look at this page
http://activemq.apache.org/producer-flow-control.html

Look at the sendFailIfNoSpace and sendFailIfNoSpaceAfterTimeout options.
These will allow the producer to fail immediately or after a set amount o
time instead of waiting indefinitely.

On Mon, Apr 4, 2016 at 11:18 AM, Paulon <oneillp@dnb.com> wrote:

> Hey,
>
> we have a setup whereby we are sending persistent messages to an MQ in
> SessionTransacted batches.
>
> The problem we are facing is that if the MQ fills up, our producer blocks
> indefinitely.
>
> We dont have control over the server side queue, so we need to be able to
> abort sending (rather than wait forever)
>
> We have set the sendTimeout on the connectionFactory however, while this
> throws the expected exception, any attempt to do a session.close() blocks
> waiting for a Response object.
>
> Is there a way to get the blocked send call to just fail/timeout to enable
> us to close the session/connection object and terminate the thread/process?
>
> Otherwise we are at the mercy of a slow/poorly configured consumer that can
> block our system.
>
> Cheers!
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Force-Producer-to-fail-when-blocked-by-slow-consumer-tp4710264.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

--001a114718c6d06b09052faad7ba--