From 2769d0a4d12340e68a10dd64f82aa95d6d987c08 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/qpid@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 'java/common/src/main') diff --git a/java/common/src/main/java/org/apache/qpid/transport/Session.java b/java/common/src/main/java/org/apache/qpid/transport/Session.java index 8877b7b683..22561dcc33 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/Session.java +++ b/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/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java b/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java index 7cc0ed6617..520291e71c 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java +++ b/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