You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2007/11/13 13:02:06 UTC
svn commit: r594500 -
/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/impl/ClientSession.java
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()