summaryrefslogtreecommitdiff
path: root/java
diff options
context:
space:
mode:
Diffstat (limited to 'java')
-rw-r--r--java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java7
1 files changed, 6 insertions, 1 deletions
diff --git a/java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java b/java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java
index 247e691c78..af41312532 100644
--- a/java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java
+++ b/java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java
@@ -39,7 +39,12 @@ public abstract class SessionDelegate
if (method.getEncodedTrack() == Frame.L4)
{
method.setId(ssn.nextCommandId());
- method.dispatch(ssn, this);
+ }
+
+ method.dispatch(ssn, this);
+
+ if (method.getEncodedTrack() == Frame.L4)
+ {
if (!method.hasPayload())
{
ssn.processed(method);