diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2008-06-13 12:24:10 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2008-06-13 12:24:10 +0000 |
| commit | 0c4e91133e5012cd480d5fa2115bcef4ce0635dd (patch) | |
| tree | 65dec01db7da6430dc107b8e56bd83875eca4893 /qpid/java/common | |
| parent | d1d0595fc5a1be8ade7b13661cd883159d8697ce (diff) | |
| download | qpid-python-0c4e91133e5012cd480d5fa2115bcef4ce0635dd.tar.gz | |
QPID-901: flush after every 64K commands issued
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@667501 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java b/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java index 7c6b7daf85..e0bdcf789e 100644 --- a/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java +++ b/qpid/java/common/src/main/java/org/apache/qpidity/transport/Session.java @@ -270,6 +270,13 @@ public class Session extends Invoker { sync(); } + + // flush every 64K commands to avoid ambiguity on + // wraparound + if ((next % 65536) == 0) + { + sessionFlush(COMPLETED); + } } } else |