svn commit: r593153 - /incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java

[arnaudsimon]

Author: arnaudsimon
Date: Thu Nov  8 05:38:08 2007
New Revision: 593153

URL: http://svn.apache.org/viewvc?rev=593153&view=rev
Log:
changed method  public void processed(Range range) for flushing when flush is 
true

Modified:
    
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java

Modified: 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java?rev=593153&r1=593152&r2=593153&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java
 Thu Nov  8 05:38:08 2007
@@ -112,7 +112,7 @@
             processed.add(range);
             flush = syncPoint != null && processed.includes(syncPoint);
         }
-        if (!flush)
+        if (flush)
         {
             flushProcessed();
         }