diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2008-02-06 22:13:31 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2008-02-06 22:13:31 +0000 |
| commit | f2de56da6296064109eee0fa42a76bf765adbfb2 (patch) | |
| tree | a7939e7e2f762b58a3f598ec099f6058f20b338a /java/common/src/main | |
| parent | 790a3ac50987c7e87ec501e1fa2438faa162ab69 (diff) | |
| download | qpid-python-f2de56da6296064109eee0fa42a76bf765adbfb2.tar.gz | |
added close notification
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@619182 13f79535-47bb-0310-9956-ffa450edef68
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 |