You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2007/04/06 15:24:47 UTC
svn commit: r526154 -
/incubator/qpid/branches/M2/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
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
{