Hi all

I suspect C++ broker does not receive the auto acknowledge message from Java.

I have a run a program like following:

Start C++ broker, with default settings
Start a Java consumer and listen to the C++ broker
The consumer session is AUTO_ACKNOWLEDGE mode
Start a Java producer and send a text message to c++ broker
Java consumer received the message normally
Java consumer exit
Java producer exit
Start Java consumer again
Now the consumer received the previous message
If consumer is set to NO_ACKNOWLEDGE mode, it wont receive previous message
It seems that C++ broker does not receive the auto acknowledge message from 
Java,

Any Idea?

Regards,
Stephen

-----------------------part of consumer codes
   Destination d = AMQDestination.createDestination(new 
AMQBindingURL("direct://dev//queue"));
   AMQConnectionFactory acf = new 
AMQConnectionFactory("amqp://user:p...@client/development?brokerlist='tcp://host:5672'");
   Connection c = acf.createConnection();
   consumerSession = c.createSession(false, AMQSession.AUTO_ACKNOWLEDGE);
   MessageConsumer messageConsumer = consumerSession.createConsumer(d);
   c.start();
----------------------part of producer codes
   Destination d = AMQDestination.createDestination(new 
AMQBindingURL("direct://dev//queue"));
   AMQConnectionFactory acf = new 
AMQConnectionFactory("amqp://user:p...@clientid/development?brokerlist='tcp://host:5672'");
   Connection c = acf.createConnection();
   AMQSession s = (AMQSession) c.createSession(false, 
AMQSession.NO_ACKNOWLEDGE);
   MessageProducer p = s.createProducer(d, false, true);
   TextMessage tm = s.createTextMessage("happy 2009!!!!");
   p.send(tm, DeliveryMode.NON_PERSISTENT, Message.DEFAULT_PRIORITY,
     Message.DEFAULT_TIME_TO_LIVE);
------------------

Reply via email to