diff options
Diffstat (limited to 'java/common/src/main')
5 files changed, 6 insertions, 0 deletions
diff --git a/java/common/src/main/java/org/apache/qpidity/ToyBroker.java b/java/common/src/main/java/org/apache/qpidity/ToyBroker.java index 2658dfcd09..2bd97f3aff 100644 --- a/java/common/src/main/java/org/apache/qpidity/ToyBroker.java +++ b/java/common/src/main/java/org/apache/qpidity/ToyBroker.java @@ -276,6 +276,7 @@ class ToyBroker extends SessionDelegate { t.printStackTrace(); } + public void closed() {} }; //hack diff --git a/java/common/src/main/java/org/apache/qpidity/ToyClient.java b/java/common/src/main/java/org/apache/qpidity/ToyClient.java index 690e729540..977704fc0c 100644 --- a/java/common/src/main/java/org/apache/qpidity/ToyClient.java +++ b/java/common/src/main/java/org/apache/qpidity/ToyClient.java @@ -73,6 +73,7 @@ class ToyClient extends SessionDelegate { t.printStackTrace(); } + public void closed() {} }); conn.send(new ConnectionEvent(0, new ProtocolHeader(1, 0, 10))); diff --git a/java/common/src/main/java/org/apache/qpidity/transport/Connection.java b/java/common/src/main/java/org/apache/qpidity/transport/Connection.java index fca7437dfd..62aba83e29 100644 --- a/java/common/src/main/java/org/apache/qpidity/transport/Connection.java +++ b/java/common/src/main/java/org/apache/qpidity/transport/Connection.java @@ -127,6 +127,7 @@ public class Connection it.remove(); } } + delegate.closed(); } public void close() diff --git a/java/common/src/main/java/org/apache/qpidity/transport/ConnectionDelegate.java b/java/common/src/main/java/org/apache/qpidity/transport/ConnectionDelegate.java index b497a56f78..001ad7220c 100644 --- a/java/common/src/main/java/org/apache/qpidity/transport/ConnectionDelegate.java +++ b/java/common/src/main/java/org/apache/qpidity/transport/ConnectionDelegate.java @@ -69,6 +69,8 @@ public abstract class ConnectionDelegate extends MethodDelegate<Channel> public abstract void exception(Throwable t); + public abstract void closed(); + public void setCondition(Lock negotiationCompleteLock,Condition negotiationComplete) { _negotiationComplete = negotiationComplete; diff --git a/java/common/src/main/java/org/apache/qpidity/transport/Echo.java b/java/common/src/main/java/org/apache/qpidity/transport/Echo.java index a3ac24dc48..03d0d3e161 100644 --- a/java/common/src/main/java/org/apache/qpidity/transport/Echo.java +++ b/java/common/src/main/java/org/apache/qpidity/transport/Echo.java @@ -74,6 +74,7 @@ public class Echo extends SessionDelegate { t.printStackTrace(); } + public void closed() {} }; //hack |