I've been experimenting with various flow control scenarios and all the
"standard" scenarios worked as expected (sync/async sends with
sendFailIfNoSpace set/not on the broker side) - I'm seeing
blocking/AllocationException/nothing in the client depending on the
scenario.
What I really want is what
There is no correct way, both are correct. Calling close() to
unsubscribe and session.addConsumer() to subscribe again is the most
efficient... but if you can detect the hang and again return from your
listener or call receive() again that will also suffice.
When you say hang, what component bloc
Hi,
1) Its the call to javax.jms.Connection.createSession(boolean transacted, int
acknowledgeMode) where you can specify whether your Session is transacted or
not.
So its basically a flag.
2) The acknowledge mode is passed in the above call as well. Note, the
acknowledgeMode is ignored if the
Hi all,
I'm having trouble setting a property on a received Message.
Note that I do not wish to create a new Message but simply set new
Properties on an existing Message.
in org.apache.activemq.command.ActiveMQBytesMessage, the setObjectProperty
method invokes 'initializeWriting':
public void se
I am reading the ActiveMQ Redelivery policy documentation
http://activemq.apache.org/message-redelivery-and-dlq-handling.html and this
states that :-
Messages are redelivered to a client when any of the following occurs:
A transacted session is used and rollback() is called.
A transacted session
