actory qcf = (QueueConnectionFactory) initCtx
>>> .lookup("java:comp/env/jms/MyQueueConnectionFactory");
>>>
>>> QueueConnection qcon = qcf.createQueueConnection();
>>> QueueSession qsession = qcon.createQueueSession(tru
ssion qsession = qcon.createQueueSession(true, 0);
>> Queue q = (Queue) initCtx.lookup("activemq/replyQueue");
>> QueueSender qsender = qsession.createSender(q);
>>
>> TextMessage message = qsession.createTextMessage();
>>
>>
sage();
>
> message.setText(response);
> qsender.setTimeToLive(1);
> qsender.send(message);
>
> qsender.close();
> qsession.close();
> qcon.close();
>
>
> I am quite confused as to why this is happening as I see
(message);
>
> qsender.close();
> qsession.close();
> qcon.close();
>
>
> I am quite confused as to why this is happening as I see messages as being
> available in the replyQueue.
> Any tips would be appreciated.
>
--
View this message in context:
http://www.nabble.com/Messages-not-being-received-by-consumer-tf4779201s2354.html#a13691974
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
ssage in context:
http://www.nabble.com/Messages-not-being-received-by-consumer-tf4779201s2354.html#a13672078
Sent from the ActiveMQ - User mailing list archive at Nabble.com.