qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject svn commit: r593153 - /incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java
Date Thu, 08 Nov 2007 13:38:09 GMT
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();
         }



Mime
View raw message