From 7dcc9e664a8a877fbd8adf657faa2eb5e6b41a5e Mon Sep 17 00:00:00 2001
From: "Rafael H. Schloming" <rhs@apache.org>
Date: Wed, 6 Feb 2008 22:13:31 +0000
Subject: added close notification

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@619182 13f79535-47bb-0310-9956-ffa450edef68
---
 qpid/java/common/src/main/java/org/apache/qpidity/ToyBroker.java        | 1 +
 qpid/java/common/src/main/java/org/apache/qpidity/ToyClient.java        | 1 +
 .../common/src/main/java/org/apache/qpidity/transport/Connection.java   | 1 +
 .../src/main/java/org/apache/qpidity/transport/ConnectionDelegate.java  | 2 ++
 qpid/java/common/src/main/java/org/apache/qpidity/transport/Echo.java   | 1 +
 5 files changed, 6 insertions(+)

(limited to 'qpid/java/common/src/main')

diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/ToyBroker.java b/qpid/java/common/src/main/java/org/apache/qpidity/ToyBroker.java
index 2658dfcd09..2bd97f3aff 100644
--- a/qpid/java/common/src/main/java/org/apache/qpidity/ToyBroker.java
+++ b/qpid/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/qpid/java/common/src/main/java/org/apache/qpidity/ToyClient.java b/qpid/java/common/src/main/java/org/apache/qpidity/ToyClient.java
index 690e729540..977704fc0c 100644
--- a/qpid/java/common/src/main/java/org/apache/qpidity/ToyClient.java
+++ b/qpid/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/qpid/java/common/src/main/java/org/apache/qpidity/transport/Connection.java b/qpid/java/common/src/main/java/org/apache/qpidity/transport/Connection.java
index fca7437dfd..62aba83e29 100644
--- a/qpid/java/common/src/main/java/org/apache/qpidity/transport/Connection.java
+++ b/qpid/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/qpid/java/common/src/main/java/org/apache/qpidity/transport/ConnectionDelegate.java b/qpid/java/common/src/main/java/org/apache/qpidity/transport/ConnectionDelegate.java
index b497a56f78..001ad7220c 100644
--- a/qpid/java/common/src/main/java/org/apache/qpidity/transport/ConnectionDelegate.java
+++ b/qpid/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/qpid/java/common/src/main/java/org/apache/qpidity/transport/Echo.java b/qpid/java/common/src/main/java/org/apache/qpidity/transport/Echo.java
index a3ac24dc48..03d0d3e161 100644
--- a/qpid/java/common/src/main/java/org/apache/qpidity/transport/Echo.java
+++ b/qpid/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
-- 
cgit v1.2.1