qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject svn commit: r594500 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java
Date Tue, 13 Nov 2007 12:02:06 GMT
Author: arnaudsimon
Date: Tue Nov 13 04:02:06 2007
New Revision: 594500

URL: http://svn.apache.org/viewvc?rev=594500&view=rev
Log:
Changed to use local methods instead of super ones

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

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java?rev=594500&r1=594499&r2=594500&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java
Tue Nov 13 04:02:06 2007
@@ -21,19 +21,16 @@
 {
     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 @@
         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 @@
             try
             {
                 System.out.println("count : " + count++);
-                super.data(msg.readData());
+                data(msg.readData());
             }
             catch(EOFException e)
             {
                 b = false;
             }
         }
-
-        super.endData();
+        endData();
     }
 
     public void endData()



Mime
View raw message