QPID-1219: cleanup of prior commit (r682887)

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

1 files changed, 2 insertions, 15 deletions

diff --git a/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java b/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java
index 089eb1bb17..27805a1f39 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java
@@ -90,25 +90,12 @@ public class ClientSession extends org.apache.qpid.transport.Session implements
     {
         DeliveryProperties dp = msg.getDeliveryProperties();
         MessageProperties mp = msg.getMessageProperties();
-        Header header;
-        if (msg.getHeader() == null || dp.isDirty() || mp.isDirty())
-        {
-            header = new Header(dp, mp);
-            msg.setHeader(header);
-            dp.setDirty(false);
-            mp.setDirty(false);
-        }
-        else
-        {
-            header = msg.getHeader();
-        }
-        // The javadoc clearly says that this method is suitable for small messages
-        // therefore reading the content in one shot.
         ByteBuffer  body = msg.readData();
         int size = body.remaining();
         super.messageTransfer
             (destination, MessageAcceptMode.get(acceptMode),
-             MessageAcquireMode.get(acquireMode), header, body);
+             MessageAcquireMode.get(acquireMode),
+             new Header(dp, mp), body);
         _currentDataSizeNotSynced += size;
         _currentDataSizeNotFlushed += size;
     }