From bcc3eec81fed2e1f0acd0019e055d7f47303696b Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Fri, 20 Jan 2012 20:27:59 +0000 Subject: QPID-3774 : allow out of order completion of persistent enqueues / dequeues git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1234111 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpid/transport/SessionDelegate.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) (limited to 'java/common') diff --git a/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java b/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java index 028b912ba1..cabff1cd13 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java +++ b/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java @@ -45,10 +45,15 @@ public class SessionDelegate method.dispatch(ssn, this); } - public void command(Session ssn, Method method) { + public void command(Session ssn, Method method) + { + command(ssn, method, !method.hasPayload()); + } + public void command(Session ssn, Method method, boolean processed) + { ssn.identify(method); method.dispatch(ssn, this); - if (!method.hasPayload()) + if (processed) { ssn.processed(method); } -- cgit v1.2.1