Bugs item #921450, was opened at 2004-03-22 15:44
Message generated for change (Tracker Item Submitted) made by Item Submitter
You can respond by visiting:
https://sourceforge.net/tracker/?func=detail&atid=376685&aid=921450&group_id=22866
Category: JBossMQ
Group: None
Status: Open
Resolution: None
Priority: 5
Submitted By: Elias Ross (genman)
Assigned to: Nobody/Anonymous (nobody)
Summary: QueueReceiver receives messages after Connection.stop
Initial Comment:
Connection.stop() is supposed to stop all delivery of
new messages to a MessageConsumer. However, if stop()
is called, then if Session.recover() unacknowledges
some messages, then receive() returns these un-acked
messages to the client.
The fix might be to "return" all messages from the
MessageConsumers belonging to a Connection to the server.
This code is taken from SpySession.close():
if (trace)
log.trace("Close handling unacknowledged
messages " + this);
try
{
if (spyXAResource == null)
{
if (transacted)
internalRollback();
else
{
i = unacknowledgedMessages.iterator();
while (i.hasNext())
{
SpyMessage message = (SpyMessage)
i.next();
connection.send(message.getAcknowledgementRequest(false));
i.remove();
}
}
}
}
----------------------------------------------------------------------
You can respond by visiting:
https://sourceforge.net/tracker/?func=detail&atid=376685&aid=921450&group_id=22866
-------------------------------------------------------
This SF.Net email is sponsored by: IBM Linux Tutorials
Free Linux tutorial presented by Daniel Robbins, President and CEO of
GenToo technologies. Learn everything from fundamentals to system
administration.http://ads.osdn.com/?ad_id=1470&alloc_id=3638&op=click
_______________________________________________
JBoss-Development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
