diff options
Diffstat (limited to 'java/common/src')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java | 9 |
1 files changed, 7 insertions, 2 deletions
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); } |