liquidd wrote:
>
> 3. Sending 1 incorrect messages.
> 4. Consumer doesn't aknowledge them and continuing listen for other
> message. (ActiveMQ keeps incorrect message).
> And here problem:
> 5. Sending 1 correct message.
> 6. Consumer successfully reads 1 message and 1 times acknowledges.
> 7. I
I found it!!
ActiveMQSession.INDIVIDUAL_ACKNOWLEDGE
Doctor, you are genious!
Thanks!
--
View this message in context:
http://www.nabble.com/Subscribe-%2B-Client-aknowledge-problem-tp23020938p23021595.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Ok, here what I read about receive();
"The standard behavior of this method is to cause the session to acknowledge
all messages that have been consumed by any consumer in the session since
the last time the method was invoked."
So how can I aknowledge only one message? Does using com.sun.messagi
My code:
QueueConnection s_queueConnection =
s_connectionFactory.createQueueConnection();
Session m_queueSessionConsume = s_queueConnection.createQueueSession(false,
Session.CLIENT_ACKNOWLEDGE);
Queue m_queue = m_queueSessionConsume.createQueue("MyQueue");
m_queueReceiver = m_queueSessionConsume
I have a queue,
I have a producer that sends messages to it,
And I have a consumer that synchronously reads messages (by
MessageConsumer.receive()) and acknowledges it if message is correct (my own
validation), then going to listen next messages. If it is not correct, then
it doesn't call aknowled
