svn commit: r629749 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java

[arnaudsimon]

Author: arnaudsimon
Date: Thu Feb 21 03:09:43 2008
New Revision: 629749

URL: http://svn.apache.org/viewvc?rev=629749&view=rev
Log:
changed for notifying message arrival when the header does not have a payload

Modified:
    
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java

Modified: 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java?rev=629749&r1=629748&r2=629749&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSessionDelegate.java
 Thu Feb 21 03:09:43 2008
@@ -47,6 +47,11 @@
     @Override public void header(Session ssn, Header header)
     {
         _currentMessageListener.messageHeader(header);
+        if( header.hasNoPayload())
+        {
+           _currentMessageListener.data(ByteBuffer.allocate(0));
+           _currentMessageListener.messageReceived();
+        }
     }