Re: Duplicate messages received with ActiveMQ 5.13.2

2017-07-18 Thread Tim Bain
Do you have conduitSubscriptions set to false for your networkConnectors? Or are your topics virtual and you're dynamically including both the topic and the consumer queues? Both of those could result in duplicate messages on a topic. Tim On Jul 18, 2017 6:36 AM, "tpavelka" wrote: > I have a

Re: Performance. Single producer and consumer is slow - 2 producers and 2 consumers is fast.

2017-07-18 Thread Tim Bain
Sorry, I missed the part where you said both the producers and the consumers went faster. Are the consumers simply limited by the speed of the producers (i.e. when the producer goes faster, so does the consumer)? And do you see the same behavior with no consumers at all? Tim On Jul 18, 2017 10:4

Re: Performance. Single producer and consumer is slow - 2 producers and 2 consumers is fast.

2017-07-18 Thread Tim Bain
Nothing you've described jumps out as a clear reason for the behavior you're seeing, and I've never heard anyone describe similar behavior. Do you see the same behavior with one consumer? (i.e. 1:1 is slow, 2:1 is fast?) And is it just as fast for three (or four) producers as for two, or does it g

Re: [Artemis 2.1.0] struggling to produce AMQP1.0 messages on a cluster (server side load balancing)

2017-07-18 Thread Clebert Suconic
Yep. That will work. I would keep load balance off on my system. Producers and consumers equally distributed. But I will fix this asap. (1 or 2 weeks) On Tue, Jul 18, 2017 at 8:36 PM Dan Langford wrote: > Oh great this is good news. Good in that I'm not crazy and completely inept > and y

Re: Fwd: Deadlock caused by ActiveMQMessageConsumer.dispatch() due to onEvent invocation

2017-07-18 Thread Facundo Darío Velazquez Santillán
Hi guys. I send a new message to this topic since in Mule ESB, we are suffering a deadlock again regarding to the same root cause. I am attaching the stacktrace so you can analyze this. The previous time, I applied the Tim Bain suggestion and removed a logger that called the connection.toString() m

Re: [Artemis 2.1.0] struggling to produce AMQP1.0 messages on a cluster (server side load balancing)

2017-07-18 Thread Dan Langford
Oh great this is good news. Good in that I'm not crazy and completely inept and you guys are aware of the situation. I'll make a jira ticket here in a bit. From our point of view a message is a message is a message while it's in Artemis and amqp vs core is just a distinction on how one might get a

Re: [Artemis 2.1.0] struggling to produce AMQP1.0 messages on a cluster (server side load balancing)

2017-07-18 Thread Clebert Suconic
> That message bridge is meant for core messages, and right now an > AMQPMessage would be converted to Core Message and you would receive > it as core message on the other side. I meant.. if it was working at all.. so I need some work on this. hence the 2 weeks.

Re: [Artemis 2.1.0] struggling to produce AMQP1.0 messages on a cluster (server side load balancing)

2017-07-18 Thread Clebert Suconic
I was informed about this issue last week by an user, but nobody has opened a JIRA yet.. do you want to have the honors? :) When I first wrote the refactoring on AMQPMessages right before 2.0.0 release, I was expecting users to use qpid-dispatch to load balance, and not the Message Bridge from A

[Artemis 2.1.0] struggling to produce AMQP1.0 messages on a cluster (server side load balancing)

2017-07-18 Thread Dan Langford
I could use some help. We set up an Artemis cluster (2.1.0) and at first glance it was looking great using the command line tools to produce and consumer messages verified that they were getting distributed through the cluster just fine. When we switched over to using AMQP1.0 via the qpid-jms-clien

Re: Performance. Single producer and consumer is slow - 2 producers and 2 consumers is fast.

2017-07-18 Thread Daniel
Extra info: I'm running version 5.15.0. -- View this message in context: http://activemq.2283324.n4.nabble.com/Performance-Single-producer-and-consumer-is-slow-2-producers-and-2-consumers-is-fast-tp4728648p4728649.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Performance. Single producer and consumer is slow - 2 producers and 2 consumers is fast.

2017-07-18 Thread Daniel
I've set up ActiveMQ on a host. I run one producer and one consumer. The producer is simply pumping 10 000 messages into a queue using a pooled connection. The consumer simply fetches messages. This is slow. When I add another consumer process nothing changes. When I add another producer process (

Re: Artemis 2.1.0 compatibility with 1.5.x

2017-07-18 Thread hcrobison
We are not mixing core version and jms version. -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-2-1-0-compatibility-with-1-5-x-tp4727741p4728629.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Active MQ - Master/Slave Config Not working

2017-07-18 Thread Tim Bain
Thanks for confirming that (at least at broker startup) the shared-filesystem locking is working. When you stop the master broker, do you see lines in the slave log at that exact time saying that it has acquired the lock and become the master? And after you shut down the original master, when you s

Duplicate messages received with ActiveMQ 5.13.2

2017-07-18 Thread tpavelka
I have a problem where I produce a TextMessage to a topic and the consumer receives it twice. I only have one system where I can reproduce this and I would appreciate any tips on how to debug this further. I have four JVMs, let's call them A, B, C and D. Each one runs an ActiveMQ broker. The conne

Re: Active MQ - Performance with CLIENT Ack

2017-07-18 Thread akpuvvada
TestActiveMQ.zip Attached the TIBCO BW Project I am using. It is not a Java code, TIBCO BW is a GUI (Zero Coding) Integration tool that stored the configuration in XML and converts the XMLs to Java code at Run-time and execu

Re: Active MQ - Master/Slave Config Not working

2017-07-18 Thread akpuvvada
Hi Tim, I can see logs indicating that lock is identified, please see below. 2017-07-14 03:18:14,428 | INFO | Database /tibco_installables/ActiveMQ/DataStore/kahadb/lock is locked by another server. This broker is now in slave mode waiting a lock to be acquired | org.apache.activemq.store.SharedF