From 9eea287f862b114ec70aaaaa71f4837ad6d8dbcf Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Thu, 26 Feb 2009 12:44:25 +0000 Subject: don't block unreliable commands during resume git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@748119 13f79535-47bb-0310-9956-ffa450edef68 --- .../common/src/main/java/org/apache/qpid/transport/Session.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'qpid/java/common/src') diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java index 9d2686a6f7..e3540cfd05 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java @@ -504,7 +504,11 @@ public class Session extends SessionInvoker { if (state == DETACHED && m.isUnreliable()) { - return; + Thread current = Thread.currentThread(); + if (!current.equals(resumer)) + { + return; + } } if (state != OPEN && state != CLOSED) -- cgit v1.2.1