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();
}
/**