Answering my own questionagain
So basically, just create the producer without initializing with a
queue(temporary or otherwise). This seems to be different behavior from CMS
then of JMS
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
There is example code here in Java for multiple queues for one
session(producer)
https://stackoverflow.com/questions/43537444/activemq-producer-multiple-queues-one-session
Is there a way to do this for CPP?
I've basically tried to replicate the functionality with AMQ CMS but when I
use the send
I have basically getting the same warnings I posted this to these forums over
two weeks ago and have not seen a response yet.
http://activemq.2283324.n4.nabble.com/duplicate-message-from-store-ID-snip-redirecting-for-dlq-processing-td4739238.html
It's been pretty frustrating to not hear anything
Correction to version. I amusing 5.15.2
And I forgot to mention that the response code does the following:
after retrieving the command message.
message.acknowledge(); // not sure if I even need this with client ack
TextMessage reply = qSess.createTextMessage();
reply.setText(respons
Hi folks,
I'm using JAVA AMQ version 5.13.2.
I have two queues for basic inter-service communications; a command queue
and a response queue
So I sent "status" over the command queue, and the java service responds
with "active".
The code in the lead service looks like this:
(maybe typos since I c
Ok, two years later and I am trying to update again, but still have the same
problem. Is there anybody out there that has any insight to why the receive
methods to do return?
What else do I need to post here to get a handle on this?
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-
Does anybody have any insight on this?
The first call to receive apparently works or returns. The subsequent call
to receive() never returns even with messages waiting or with a timeout set
receive(1000)
Any help would be very much appreciated.
Thanks!
--
View this message in context:
http
Where or how does one set the prefetch policy for each connection?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/AMQ-CPP-Consumer-Receive-and-receiveNoWait-does-not-return-tp4703485p4703668.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
All I can do at the moment
auto_ptr factory( new ActiveMQConectionFactory
(MY_BROKER_URL));
cms::Connection* conxn=null;
conxn=factory->CreatConnection();
auto_ptr myConn(dynamic_cast(conxn));
myConn->start();
auto_ptr mySession;
mySession.reset(myConn->CreateSession(Session::AUTO_ACKNOW
I'm trying to update to AMQ CPP 3.9.0.
The calls to the consumer receive() and receiveNoWait() will not return.
There are messages available on the queue. Older version 2.4.4 worked.
Anybody have any thoughts on this?
Thanks!
Steve
--
View this message in context:
http://activemq.2283324.n
10 matches
Mail list logo