changed for notifying message arrival when the header does not have a payload

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@629749 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 5 insertions, 0 deletions

diff --git a/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java b/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java
index a19d1016f5..f51829d834 100644
--- a/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java
+++ b/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java
@@ -47,6 +47,11 @@ public class ClientSessionDelegate extends SessionDelegate
     @Override public void header(Session ssn, Header header)
     {
         _currentMessageListener.messageHeader(header);
+        if( header.hasNoPayload())
+        {
+           _currentMessageListener.data(ByteBuffer.allocate(0));
+           _currentMessageListener.messageReceived();
+        }
     }