diff options
Diffstat (limited to 'java/common/src/main')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/transport/Session.java | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/transport/Session.java b/java/common/src/main/java/org/apache/qpid/transport/Session.java index 52e0026f29..c891c95151 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/Session.java +++ b/java/common/src/main/java/org/apache/qpid/transport/Session.java @@ -767,7 +767,17 @@ public class Session extends SessionInvoker { future = results.remove(command); } - future.set(result); + + if (future != null) + { + future.set(result); + } + else + { + log.warn("Broker sent a result in response to a command" + + " that's no longer valid on the client side." + + " [ command id : %s , result : %s ]",command, result); + } } void setException(ExecutionException exc) |