There is an embedded broker inside application, application sends messages to
this vm ,and vm forwards messages to remote broker A. there is a consumer
receiving messages on remote broker A using asyn mode.
the configure uri like this -
"vm:(broker:(network:static:(tcp://remotehostA:61616))?persis
Now, I have a JDBC master/slave cluster: tcp://remote1:61616,
tcp://remote2:61616, tcp:/remote3:61616
I start a VM , application write message to VM, then VM forward messages to
this master/slave cluster.
core code is below:
ActiveMQConnectionFactory factory = new
ActiveMQConne
suppose that application A send message to ActiveMQ B which has a queue named
"testqueue".
Can this method improve thoughtput ?
application A create more than one connections to provider, then A send
messages to the same queue (such "testqueue") using all these connections.
Can this method works
I used
"session = connection.createSession(false,2);"
to create a session. when I changto
"session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);"
Consumer can successfully dequeue message from MQ.
It works!!!
but which scenario "create.Session(false, 2)" can use?
when and wh
I'm a beginner with activemq, now I try to use method receive() in class
MessageConsumer.
yes , it can get messages successfully. but when I browse this queue, these
messages still in it?
How can I receive a message ,at same time delete this message from queue ?
since when I restart consumer , I