Yes. The code tree is as follows: Receive call on the ActiveMQMessageConsumer class, which implements the javax.jms.MessageConsumer interface… public javax.jms.Message receive() throws JMSException { checkClosed(); checkMessageListener(); sendPullCommand(0L); MessageDispatch md = dequeue(-1L); if (md == null) { return null; } beforeMessageIsConsumed(md);…
Category: Queueing
Using Spring AMQP to post messages to RabbitMQ
The ActiveMQ jar’s come with the AMQP 1.0 protocol, which doesn’t work against a RabbitMQ AMQP version 0.9.1 broker. As such, we use a spring jar to get this to work, thanks to this link. Very simple example of this.…
ActiveMQ using a single connection for multiple consumers
We had a need to test this, as a WebMethods installation that uses what they call Triggers had the configuration noted in the title of the post. Not much other detail, just an example for someone who may wander by…