Hi Ceposta,
I already added a debug point for that method, but it never hit when I
subscribe to broker B. But AbstractRegion#addConsumer method got hit when I
add a debug point. Is there anyway to capture broker B's information within
AbstractRegion class ?
Regards,
Gihan
--
View this messag
Thanks Christian. Yes, I do see the exception in my logs which I had already
mentioned in my first post in this thread. I wanted to handle all exceptions
in a generic way in ExceptionListener instead of handling async and sync
exceptions differently. Is there any support in ActiveMQ to get callback
Gary Tully writes:
>
> For destination D you still need to specify a real/concrete strategy,
> either individualDeadLetterStrategy or shared will work:
>
>
>
>
>
>
>
> On 1 April 2010 10:40, Jan Dev wrote:
>
> >
> > Hi all
> >
> > I am using ActiveMQ 5.3.0.
> > I have lots of queue
Hi guys, something to think about is sirona/hawtio I think. Any ideas?
Goals are not exactly the same but there are some overlaps so I'd expect
sirona amq, camel etc plugins.
Le 29 oct. 2013 21:19, "Hiram Chirino" a écrit :
> You could also post process that hawtio bits. It gets packaged in the
non-persistent messages are never stored in leveldb so that should not
be a factor.
On Wed, Oct 23, 2013 at 1:52 PM, kal123 wrote:
> We see only 1-4 per second msgs when we use leveldb and msg are
> non-persistence and consumers are running. With kahadb the rate is 6000
> msgper/sec.
> what coul
You could also post process that hawtio bits. It gets packaged in the
assembly module. Right now the
assembly/src/main/descriptors/common-bin.xml file handles unpacking
the hawtio bits into the activemq distro. You could overwrite any
bits that are needed there.
On Fri, Oct 25, 2013 at 10:40 AM
It's not clear from your settings whether producer flow control is on/off.
But either way, as far as i remember, the store positions (and thus usage)
are updated at checkpoints (default every 5s)...
If you could put together a quick unit test that shows your issues (i see
you already have some ja
Do you see the exception anywhere in your logs?
the exception listener is for async sends resulting in an error. the
connection info is sent sync, so you should see the exception on the same
thread as that creating the connection.
On Tue, Oct 29, 2013 at 1:46 AM, Steven Turner wrote:
> This iss
Take a look at DemandForwardingBridgeSupport#addConsumerInfo
This is where broker A will take information from broker B and try to add a
proxy consumer.
On Tue, Oct 29, 2013 at 2:56 AM, Gihan wrote:
> Hi Ceposta,
>
> I checked several methods in DemandForwardingBridgeSupport class putting
> de
Hi,
I too have experimented with ExceptionListener in the past with no success.
I think the exception is invoked in some cases and not in some cases and
perhaps the implementation is buggy.
ActiveMQ developer team would be best to comment on this. This sounds like a
basic requirement to have in
Hi Ceposta,
I checked several methods in DemandForwardingBridgeSupport class putting
debug points. I subscribed to broker B while I'm debugging broker A. But
none of the debug point got invoke during the subscribe.
Could you please point me few methods that I need to give focus ?
Thanks.
--
Greetings
I am experiencing a couple of issues while using ActiveMQ 5.8. They are:
1) Redelivery policy is not being applied correctly.
2) ActiveMQ broker is not adhering to set usage constraints. The queue
is filling up until it runs out of diskspace
despite the fact that store limits are se
This issue seems to be happening even if I use the raw ActiveMQ API instead
of using the Spring's JmsTemplate. If I just set ExceptionListener on the
ActiveMQ connection or connectionfactory, it is not getting invoked for
exceptions as part of ActiveMQConnection.start().
It looks to me from the co
Hi,
I have a custom plugin on the broker side which throws an exception in some
cases from addConnection. I would like to handle this exception on the
client side. My client uses JmsTemplate for sending messages. I am using
ActiveMQConnectionFactory.setExceptionListener to set a listener but this
This is what I am doing:
public class ActiveMQAuthConnectionFactory extends
org.apache.activemq.ActiveMQConnectionFactory
{
private static class AMQExceptionListener implements ExceptionListener
{
@Override
public void onException(JMSException exception)
{
15 matches
Mail list logo
