[jBoss-Dev] CVS update: spyderMQ/src/java/org/spyderMQSpyConnection.java

[jBoss CVS Development]

  User: norbert 
  Date: 00/05/30 16:17:00

  Modified:    src/java/org/spyderMQ SpyConnection.java
  Log:
  Add new operators to the Selector object
  
  Revision  Changes    Path
  1.33      +6 -6      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.32
  retrieving revision 1.33
  diff -u -r1.32 -r1.33
  --- SpyConnection.java        2000/05/30 22:10:18     1.32
  +++ SpyConnection.java        2000/05/30 23:17:00     1.33
  @@ -29,7 +29,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.32 $
  + *   @version $Revision: 1.33 $
    */
   public class SpyConnection 
                implements Connection, Serializable
  @@ -83,9 +83,9 @@
        }
   
   
  -        public void setClientID(String cID) throws JMSException
  -        {
  -                if (closed) throw new IllegalStateException("The connection is 
closed");
  +    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");
   
                Log.log("SetClientID("+clientID+")");
  @@ -101,7 +101,7 @@
                clientID=cID;
        }
    
  -        public ConnectionMetaData getMetaData() throws JMSException
  +     public ConnectionMetaData getMetaData() throws JMSException
        {
                if (closed) throw new IllegalStateException("The connection is 
closed");                
                
  @@ -124,7 +124,7 @@
                exceptionListener=listener;
        }
   
  -        public void start() throws JMSException
  +     public void start() throws JMSException
        {
                if (closed) throw new IllegalStateException("The connection is 
closed");
                if (distributedConnection==null) createReceiver();