Author: rgodfrey
Date: Fri Apr 6 06:24:46 2007
New Revision: 526154
URL: http://svn.apache.org/viewvc?view=rev&rev=526154
Log:
QPID-443 : Fix to transactionality of message publishing
Modified:
incubator/qpid/branches/M2/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
Modified:
incubator/qpid/branches/M2/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2/java/client/src/main/java/org/apache/qpid/client/AMQSession.java?view=diff&rev=526154&r1=526153&r2=526154
==============================================================================
---
incubator/qpid/branches/M2/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
(original)
+++
incubator/qpid/branches/M2/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
Fri Apr 6 06:24:46 2007
@@ -327,8 +327,11 @@
") is closed
rejecting(requeue)...");
}
}
-
- rejectMessage(message, true);
+ // Don't reject if we're already closing
+ if(!_closed.get())
+ {
+ rejectMessage(message, true);
+ }
}
else
{
