Re: Stomp over websocket connections timeout/hearbeat

I have AMQ 5.8.0 so i think the good choice for me is use heartbeat.outgoing and incoming parameters in the client side. Thanks for all your answers. Best regards, 2015-09-28 18:38 GMT+02:00 Christopher Shannon < christopher.l.shan...@gmail.com>: > I think you can also configure the heart beat

Re: Nothing on queues, Journal files not getting cleaned up

I trust you've confirmed that there are no messages pending on topics as well as queues? JMX is the easiest way I know to confirm that if you haven't already done so. Are some but not all journal files being deleted, or none at all? On Sep 28, 2015 8:44 AM, wrote: > Hello, > > How is it that ou

Re: ActiveMQ Network of Brokers plus HA for messages

They're mutually exclusive within a specific cluster of nodes, but you can compose a network of brokers out of multiple master/slave cluster. So (to pick a random example) if you have clusters made of M1/S1, M2/S2, and M3/S3 and wanted a NOB with connections between clusters 1 and 2 and between 2

Re: The consumer thread closed right after producer thread finishes sending messages.

Now I'm confused. Are you doing C++ or Java? You referenced both .cpp files and the JVM, and I don't know how those two go together. Unless you mean that the broker's JVM is exiting when being accessed by C++ clients? Also, I assumed (since you haven't clearly said one way or the other) that you

ActiveMQ Network of Brokers plus HA for messages

We have been looking at options for configuring HA with AMQ/ActiveMQ. Our requirements are: 1. Active/Active broker connectivity – producers and consumers can connect to any broker. 2. No loss of persistent messages in the event a broker node fails. Based on reading of the ActiveMQ doc

Re: The consumer thread closed right after producer thread finishes sending messages.

I did have these lines in main. producerThread.join(); consumerThread.join(); and in run() in Consumer.cpp, I have latch.countDown(); and in onMessage() in Consumer.cpp, I have doneLatch.countDown(); Am I doing right ? But I am having a problem to understand what they are for. I made

Re: The consumer thread closed right after producer thread finishes sending messages.

Is the producer your last non-daemon thread? If so, the JVM will exit when that thread exits, but you could use a synchronization construct such as a countdown latch or a call to Thread.join() to make the producer thread not exit till the consumer does. On Sep 28, 2015 7:21 PM, "mfan" wrote: > I

The consumer thread closed right after producer thread finishes sending messages.

I am trying to write an application that a producer (with PERSISTENT delivery mode) sends 8 messages to asynchronous a consumer. Both producer and consumer are in acknowledgement mode (AUTO_ACKNOWLEDGE). After the consumer received a message, it will do some work. Somehow the producer produci

Duplex isn't working connecting an embedded broker to a external broker

Duplex isn't working connecting an embedded broker to a external broker. I'm using Apache TomEE with this URL: BrokerXmlConfig = broker:(vm://tomee1,network:static:(tcp://external-activemq-server:61616)?duplex=true)?persistent=true&brokerName=tomee1 I *do* see the connection on the ActiveMQ Cons

Activemq-cpp Synchronous Receive from Multiple Consumers

Hi, Sorry, this is a bit of a long post/question... I have an application where I need to use the synchronous API of the activemq-cpp library where I will have one thread that needs to subscribe to, and receive messages from, multiple topics. After studying the API docs, I don't see a way to effic

Re: Stomp over websocket connections timeout/hearbeat

I think you can also configure the heart beat in the connect frame of a STOMP session by setting the heart-beat header. https://stomp.github.io/stomp-specification-1.1.html#Heart-beating On Mon, Sep 28, 2015 at 12:14 PM, Christopher Shannon < christopher.l.shan...@gmail.com> wrote: > Yes you can

Re: Stomp over websocket connections timeout/hearbeat

Yes you can use heartbeats and it gets configured by using the inactivity monitor settings. There was also a bug just fixed for it in 5.12.0: https://issues.apache.org/jira/browse/AMQ-5155 To configure this on the server side you just need to set the inactivity monitor for the timeout period you

Nothing on queues, Journal files not getting cleaned up

Hello, How is it that our journal files continue to grow, yet no messages are on the queues? ActiveMQ 5.11.1, Using KahaDB (not levelDB). How can you tell if a kahaDB scheduler is waiting, and in need of clearing? Nothing on the Advisory queues (no network of brokers), nothing on the DLQ. Wh

Stomp over websocket connections timeout/hearbeat

Hi, Im using stomp over websocket protocol... my actual broker configuration is very simple... I would like to use heartbeat parameter like in stomp configuration: stomp://0.0.0.0:0?transport.defaultHeartBeat=5000 Or in openwire...

different users for console and REST API

Hi, Is it possible to have different users for the console and the REST interface at *:8161/api/message/? looks like whatever I put into /opt/activemq/conf/credentials.properties and /opt/activemq/conf/users.properties has access to everything (I'm using AMQ 5.12.0 if that matters). I'm includin

Broken documentation

The do http://activemq.apache.org/version-5-installation.html and http://activemq.apache.org/version-5-topologies.html -- View this message in context: http://activemq.2283324.n4