From 3430d8e2d64d41a5cd51e66eb2d8d263270d04aa Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Tue, 23 Dec 2008 21:09:48 +0000 Subject: QPID-1549: don't throw not implemented when we get a flush with the expected bit set git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@729118 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpid/transport/Session.java | 13 +++++++++++++ .../java/org/apache/qpid/transport/SessionDelegate.java | 2 +- 2 files changed, 14 insertions(+), 1 deletion(-) (limited to 'qpid/java/common/src/main') diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java index 8877b7b683..22561dcc33 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java @@ -312,6 +312,19 @@ public class Session extends SessionInvoker } } + void flushExpected() + { + RangeSet rs = new RangeSet(); + synchronized (processedLock) + { + if (incomingInit) + { + rs.add(commandsIn); + } + } + sessionExpected(rs, null); + } + public void flushProcessed(Option ... options) { RangeSet copy; diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java index 7cc0ed6617..520291e71c 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java @@ -115,7 +115,7 @@ public class SessionDelegate } if (flush.getExpected()) { - throw new Error("not implemented"); + ssn.flushExpected(); } } -- cgit v1.2.1