diff --git a/src/org/atriasoft/esignal/Connection.java b/src/org/atriasoft/esignal/Connection.java index 68aec53..019dfdb 100644 --- a/src/org/atriasoft/esignal/Connection.java +++ b/src/org/atriasoft/esignal/Connection.java @@ -3,7 +3,7 @@ package org.atriasoft.esignal; import java.lang.ref.WeakReference; public class Connection implements AutoCloseable { - protected final WeakReference connection; + protected WeakReference connection; public void disconnect() { close(); @@ -27,5 +27,17 @@ public class Connection implements AutoCloseable { return; } tmp.disconnect(this); + this.connection = null; + } + + public boolean isConnected() { + if (this.connection == null) { + return false; + } + ConnectionRemoveInterface tmp = this.connection.get(); + if (tmp == null) { + return false; + } + return true; } }