Re: ActiveMq 'Queue Priority Consumer' Mechanism Not Working Expectedly

Hi I have never used consumer priorities, but the amq-website says about it *** Once a particular consumer has its prefetch buffer filled up, the broker will begin to dispatch messages to consumers of lower priorities. *** So, the behaviour you describe seems to be ok to me. When the high prio co

Re: Separate persistence provider per queue

To be clear, this is with ActiveMQ 5.x. The setup is that there is a single broker on a particular host whose purpose is to forward on messages from several queues to another host which is shared by multiple other hosts. The dataDirectory for the broker is a network location which is shared by mu

RE: [Artemis, Qpid JMS] Sending persistent message to Artemis blocks while transformer runs?

Thank you for the suggestion -- I'll look in to the approach recommended. Regards, --Matthew -Original Message- From: Justin Bertram [mailto:jbert...@apache.com] Sent: 03 May 2016 15:12 To: users@activemq.apache.org Subject: Re: [Artemis, Qpid JMS] Sending persistent message to Artemis b

Re: [Artemis, Qpid JMS] Sending persistent message to Artemis blocks while transformer runs?

> That leaves the option of an out-of-band transformer, it would seem? That would be my recommendation. Have a local consumer which receives the message and makes the necessary REST call(s) back to A and then finally sends the message where it needs to go. Justin - Original Message -

ActiveMq 'Queue Priority Consumer' Mechanism Not Working Expectedly

Hi all, We are using ActiveMq in our application. We need to implement priority consumer mechanism on the queue. We have multiple consumers and we want to treat them as master/slave. So, the master consumer would have higher priority and will consume all messages and once master gets down then the

RE: [Artemis, Qpid JMS] Sending persistent message to Artemis blocks while transformer runs?

Hello Justin, Thank you very much for the response. We have messages being sent from A. These messages need to be small to avoid slowing down A. However, B and C require more information than is contained within the initial message sent by A. We therefore have two transformers that augment the

Re: [Artemis, Qpid JMS] Sending persistent message to Artemis blocks while transformer runs?

A durable message won't be acknowledged by the broker until it is written to disk. The transformation is almost certainly being done before the message is written to disk so the sender ostensibly must wait for the transformation to complete before it receives the ack from the broker. Potential

[Artemis, Qpid JMS] Sending persistent message to Artemis blocks while transformer runs?

Hello All, I have a Qpid JMS messaging client sending a persistent message to Artemis. I am finding that the send() method is blocking until the transformer I have configured in Artemis completes (which takes several seconds). Can I confirm that this is intended behaviour? i.e. if a client sends

[ANNOUNCE] Apache ActiveMQ 5.13.3 Released

Hi Everyone, The Apache ActiveMQ team is pleased to announce that version 5.13.3 has been released. This release contains over 25 improvements and bug fixes found since the 5.13.2 release. A list of issues fixed in this release is available here: https://issues.apache.org/jira/secure/ReleaseNote

Advisory Messages -isRemoveInfo() methods in activemq 5.13.2

Hi, I am trying to see if isRemoveInfo() methods is working fine. if (cmd->isRemoveInfo()) { Client()->LogEvent(DEBUG_LOG,0, "coreCMS::onMessage" "cmd->isRemoveInfo(), Node has been removed");