diff options
Diffstat (limited to 'qpid/java/client/src/main/java/org/apache/qpid/client/Closeable.java')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/Closeable.java | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/Closeable.java b/qpid/java/client/src/main/java/org/apache/qpid/client/Closeable.java index 7e119343a1..e6771e122c 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/Closeable.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/Closeable.java @@ -52,6 +52,13 @@ public abstract class Closeable protected final AtomicBoolean _closed = new AtomicBoolean(false); /** + * Are we in the process of closing. We have this distinction so we can + * still signal we are in the process of closing so other objects can tell + * the difference and tidy up. + */ + protected final AtomicBoolean _closing = new AtomicBoolean(false); + + /** * Checks if this is closed, and raises a JMSException if it is. * * @throws JMSException If this is closed. @@ -75,6 +82,17 @@ public abstract class Closeable } /** + * Checks if this is closis. + * + * @return <tt>true</tt> if we are closing, <tt>false</tt> otherwise. + */ + public boolean isClosing() + { + return _closing.get(); + } + + + /** * Closes this object. * * @throws JMSException If this cannot be closed for any reason. |