Changed to use local methods instead of super ones

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

1 files changed, 6 insertions, 10 deletions

diff --git a/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java b/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java
index 3834f043eb..89da0bb691 100644
--- a/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java
+++ b/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java
@@ -21,19 +21,16 @@ public class ClientSession extends org.apache.qpidity.transport.Session implemen
 {
     static
     {
-        MAX_NOT_SYNC_DATA_LENGH = 200000 * 1024;
         String max = "message_size_before_sync";
-        if (System.getProperties().containsKey(max))
-        {
             try
             {
-                MAX_NOT_SYNC_DATA_LENGH = new Long(System.getProperties().getProperty(max));
+                MAX_NOT_SYNC_DATA_LENGH = new Long(System.getProperties().getProperty(max, "200000000"));
             }
             catch (NumberFormatException e)
             {
                 // use default size
+                MAX_NOT_SYNC_DATA_LENGH = 200000000;
             }
-        }
     }
 
     private static  long MAX_NOT_SYNC_DATA_LENGH;
@@ -66,8 +63,8 @@ public class ClientSession extends org.apache.qpidity.transport.Session implemen
         ByteBuffer  data = msg.readData();
         super.messageTransfer(destination, confirmMode, acquireMode);
         super.header(msg.getDeliveryProperties(),msg.getMessageProperties());
-        super.data( data );
-        super.endData();
+        data( data );
+        endData();
     }
 
     public void sync()
@@ -109,15 +106,14 @@ public class ClientSession extends org.apache.qpidity.transport.Session implemen
             try
             {
                 System.out.println("count : " + count++);
-                super.data(msg.readData());
+                data(msg.readData());
             }
             catch(EOFException e)
             {
                 b = false;
             }
         }
-
-        super.endData();
+        endData();
     }
 
     public void endData()