User: hiram
Date: 00/11/16 14:39:46
Modified: src/java/org/spydermq SpyConnection.java
Log:
Update for the new UIL classes to work
Revision Changes Path
1.14 +13 -7 spyderMQ/src/java/org/spydermq/SpyConnection.java
Index: SpyConnection.java
===================================================================
RCS file: /products/cvs/ejboss/spyderMQ/src/java/org/spydermq/SpyConnection.java,v
retrieving revision 1.13
retrieving revision 1.14
diff -u -r1.13 -r1.14
--- SpyConnection.java 2000/11/12 00:29:08 1.13
+++ SpyConnection.java 2000/11/16 22:39:46 1.14
@@ -31,7 +31,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.13 $
+ * @version $Revision: 1.14 $
*/
public class SpyConnection
implements Connection, Serializable
@@ -91,8 +91,8 @@
}
- public void setClientID(String cID) throws JMSException
- {
+ public void setClientID(String cID) throws JMSException
+ {
if (closed) throw new IllegalStateException("The connection is closed");
if (clientID!=null) throw new IllegalStateException("The connection
has already a clientID");
@@ -150,7 +150,7 @@
}
- public void stop() throws JMSException
+ public void stop() throws JMSException
{
if (closed) throw new IllegalStateException("The connection is
closed");
if (distributedConnection==null) createReceiver();
@@ -168,7 +168,7 @@
}
- public synchronized void close() throws JMSException
+ public synchronized void close() throws JMSException
{
if (closed) return;
@@ -192,7 +192,7 @@
} catch (Exception e) {
failureHandler(e,"Cannot close properly the connection");
}
-
+
// Only set the closed flag after all the objects that depend
// on this connection have been closed.
closed=true;
@@ -432,4 +432,10 @@
throw excep;
}
-}
+/**
+ * Creation date: (11/16/2000 2:20:22 PM)
+ * @return org.spydermq.distributed.interfaces.DistributedJMSServer
+ */
+public org.spydermq.distributed.interfaces.DistributedJMSServer getProvider() {
+ return provider;
+}}