You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/03/21 15:12:07 UTC

svn commit: r387531 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java

Author: jstrachan
Date: Tue Mar 21 06:12:05 2006
New Revision: 387531

URL: http://svn.apache.org/viewcvs?rev=387531&view=rev
Log:
made more properties public; "closing", "closed" and "transportFailed"

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java?rev=387531&r1=387530&r2=387531&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java Tue Mar 21 06:12:05 2006
@@ -418,13 +418,6 @@
     }
 
     /**
-     * @return true if this Connection is started
-     */
-    protected boolean isStarted() {
-        return started.get();
-    }
-
-    /**
      * Temporarily stops a connection's delivery of incoming messages. Delivery
      * can be restarted using the connection's <CODE>start</CODE> method. When
      * the connection is stopped, delivery to all the connection's message
@@ -673,6 +666,36 @@
     // -------------------------------------------------------------------------
 
     /**
+     * Returns true if this connection has been started
+     * 
+     * @return true if this Connection is started
+     */
+    public boolean isStarted() {
+        return started.get();
+    }
+
+    /**
+     * Returns true if the connection is closed
+     */
+    public boolean isClosed() {
+        return closed.get();
+    }
+
+    /**
+     * Returns true if the connection is in the process of being closed
+     */
+    public boolean isClosing() {
+        return closing.get();
+    }
+    
+    /**
+     * Returns true if the underlying transport has failed
+     */
+    public boolean isTransportFailed() {
+        return transportFailed.get();
+    }
+    
+    /**
      * @return Returns the prefetchPolicy.
      */
     public ActiveMQPrefetchPolicy getPrefetchPolicy() {
@@ -1143,10 +1166,6 @@
                 throw JMSExceptionSupport.create(e);
             }
         }
-    }
-
-    public boolean isClosed() {
-        return closed.get();
     }
 
     /**