Load balancing based on topics

Hi, Can someone please explain me how Artemis performs load balancing with topics? I understand somewhat about how it does with jms queues but I don't understand how the load balancing is done with respect to topics. Also is a there a way I can configure Artemis to evenly distribute topics among d

Re: java.io.EOFException when ActiveMQ starts

It looks like the broker is failing to make the connection described in your networkConnectors section of activemq.xml. Can you show us that config snippet? And do you have any reason to believe that connection might be failing? Tim On Oct 7, 2016 2:44 AM, "divinedragon" wrote: I am trying to

Re: ActiveMQ REST message listener

I'd also be curious to hear more about "I don't want to use the tcp connection as it will be closed," since that seems to be driving your requirements but doesn't make sense to me as stated. Tim On Oct 7, 2016 3:40 AM, "Martyn Taylor" wrote: The REST over HTTP pattern is request/response you se

Re: Messaging listener for local messages only

I'd start with Justin's suggestions, if those are not possible it might be possible add an outbound interceptor that increments a message property with a counter "NUMBER_OF_HOPS". It would get triggered every time the message is forwarded to a broker or client. This way you can figure out how man

Re: Duplicating messages published to a Topic to a Queue

I don't have enough information to understand you problem fully. But perhaps you could use a combination of duplicate detection and diverts could solve your problem. https://activemq.apache.org/artemis/docs/1.4.0/duplicate-detection.htm https://activemq.apache.org/artemis/docs/1.4.0/diverts.html

Re: ActiveMQ REST message listener

The REST over HTTP pattern is request/response you send a GET request and you "get" a response. By it's very nature is going to require polling. I'm not sure what your requirements are, but if you are trying to do this stuff in a browser, then using Websockets as John suggested could get you what

java.io.EOFException when ActiveMQ starts

I am trying to start the ActiveMQ 5.11 and I see a WARNING as below: WARN | Transport Connection to: tcp://127.0.0.1:40890 failed: java.io.EOFException Here is the entire console log for this. Java Runtime: Oracle Corporation 1.7.0_05 /usr/java/jdk1.7.0_05/jre Heap sizes: current=1004928k free=9