JMS, Queue - принцип работы!
Помогите кто разбирается в JMS:
Правильно ли я понял прочтенное:
Сообщения отправленные в Queue могут быть получены только ОДИН раз ОДНИМ клиентом. ??
Я так понимаю что они должны удаляться из очереди??
пытаюсь писать пример:
[code]QueueConnectionFactory queueConnFactory = (QueueConnectionFactory)ctx.lookup("jmsf actory/default/QueueConnectionFactory");
QueueConnection qConn = queueConnFactory.createQueueConnection() ;
qConn.start();
QueueSession qSession = qConn.createQueueSession(true, 0);
Queue queue = (Queue)ctx.lookup("jmsqueues/default/Tes tQueue");
QueueReceiver qReceiver = qSession.createReceiver(queue);
TextMessage message = (TextMessage) qReceiver.receive(1000);
String mes = message.getText();
qSession.commit();
qSession.close();
qConn.stop();[/code]
так вот у меня не удаляется сообщение из очереди... Я могу его постоянно считывать.
Что я не так понял?
Правильно ли я понял прочтенное:
Сообщения отправленные в Queue могут быть получены только ОДИН раз ОДНИМ клиентом. ??
Я так понимаю что они должны удаляться из очереди??
пытаюсь писать пример:
[code]QueueConnectionFactory queueConnFactory = (QueueConnectionFactory)ctx.lookup("jmsf
QueueConnection qConn = queueConnFactory.createQueueConnection()
qConn.start();
QueueSession qSession = qConn.createQueueSession(true, 0);
Queue queue = (Queue)ctx.lookup("jmsqueues/default/Tes
QueueReceiver qReceiver = qSession.createReceiver(queue);
TextMessage message = (TextMessage) qReceiver.receive(1000);
String mes = message.getText();
qSession.commit();
qSession.close();
qConn.stop();[/code]
так вот у меня не удаляется сообщение из очереди... Я могу его постоянно считывать.
Что я не так понял?
