[jBoss-Dev] CVS update:spyderMQ/src/java/org/spydermq/distributed/interfacesConnectionReceiver.java DistributedJMSServer.java

[jBoss CVS Development]

  User: norbert 
  Date: 00/05/31 11:10:15

  Added:       src/java/org/spydermq/distributed/interfaces
                        ConnectionReceiver.java DistributedJMSServer.java
                        DistributedQueueConnectionFactory.java
                        DistributedTopicConnectionFactory.java
  Log:
  Change the directory name
  
  Revision  Changes    Path
  1.1                  
spyderMQ/src/java/org/spydermq/distributed/interfaces/ConnectionReceiver.java
  
  Index: ConnectionReceiver.java
  ===================================================================
  /*
   * spyderMQ, the OpenSource JMS implementation
   *
   * Distributable under GPL license.
   * See terms of license at gnu.org.
   */
  package org.spydermq.distributed.interfaces;
  
  import javax.jms.Destination;
  import org.spydermq.SpyMessage;
  import org.spydermq.SpyConnection;
  import org.spydermq.SpyDestination;
  
  /**
   *    This interface implements one callback for the Connection object
   *      
   *    @author Norbert Lataille ([EMAIL PROTECTED])
   * 
   *    @version $Revision: 1.1 $
   */
  
  public interface ConnectionReceiver 
  {
        // Public --------------------------------------------------------
  
        //A message has arrived for the Connection 
      public void receive(Destination dest,SpyMessage mes) throws Exception;    
        //Many messages have arrived for this Connection 
      public void receiveMultiple(Destination dest,SpyMessage mes[]) throws Exception; 
 
        //One TemporaryDestination has been deleted
      public void deleteTemporaryDestination(SpyDestination dest) throws Exception;    
 
        //The connection is closed
      public void close() throws Exception;     
        //set the current connection
        public void setConnection(SpyConnection connection) throws Exception;
  }
  
  
  
  1.1                  
spyderMQ/src/java/org/spydermq/distributed/interfaces/DistributedJMSServer.java
  
  Index: DistributedJMSServer.java
  ===================================================================
  /*
   * spyderMQ, the OpenSource JMS implementation
   *
   * Distributable under GPL license.
   * See terms of license at gnu.org.
   */
  package org.spydermq.distributed.interfaces;
  
  import javax.jms.JMSException;
  import javax.jms.Destination;
  import javax.jms.Topic;
  import javax.jms.Queue;
  import javax.jms.TemporaryTopic;
  import javax.jms.TemporaryQueue;
  import org.spydermq.SpyMessage;
  import org.spydermq.SpyDestination;
  import org.spydermq.JMSServer;
  import org.spydermq.SpyDistributedConnection;
  
  /**
   *    This interface implements callbacks for the JMSServer object 
   *      
   *    @author Norbert Lataille ([EMAIL PROTECTED])
   * 
   *    @version $Revision: 1.1 $
   */
  public interface DistributedJMSServer
  { 
        // Public --------------------------------------------------------
  
        public String getID() throws Exception;
      public void newMessage(SpyMessage val[],String id) throws Exception;
      public void subscribe(Destination dest,SpyDistributedConnection who) throws 
Exception;
        public void unsubscribe(Destination dest,SpyDistributedConnection who) throws 
Exception;
        public Topic createTopic(String dest) throws Exception;
        public Queue createQueue(String dest) throws Exception;
        public TemporaryTopic getTemporaryTopic(SpyDistributedConnection dc) throws 
Exception;
        public TemporaryQueue getTemporaryQueue(SpyDistributedConnection dc) throws 
Exception;
        public void deleteTemporaryDestination(SpyDestination dest) throws Exception;
        public void connectionClosing(SpyDistributedConnection dc) throws Exception;   
 
        public void setServer(JMSServer s) throws Exception; 
        public void checkID(String ID) throws Exception;
        public SpyMessage queueReceiveNoWait(Queue queue) throws Exception;
        public void connectionListening(boolean mode,Destination 
dest,SpyDistributedConnection dc) throws Exception;
  }
  
  
  
  1.1                  
spyderMQ/src/java/org/spydermq/distributed/interfaces/DistributedQueueConnectionFactory.java
  
  Index: DistributedQueueConnectionFactory.java
  ===================================================================
  /*
   * spyderMQ, the OpenSource JMS implementation
   *
   * Distributable under GPL license.
   * See terms of license at gnu.org.
   */
  package org.spydermq.distributed.interfaces;
  
  import javax.jms.QueueConnection;
  import org.spydermq.security.SecurityManager;
  
  /**
   *    This is the interface for a distributed QueueConnectionFactory. 
   *      
   *    @author Norbert Lataille ([EMAIL PROTECTED])
   * 
   *    @version $Revision: 1.1 $
   */
  public interface DistributedQueueConnectionFactory
  {
        // Public --------------------------------------------------------
  
        public QueueConnection createQueueConnection() throws Exception;
      public QueueConnection createQueueConnection(String userName, String password) 
throws Exception;
        
        public void setServer(DistributedJMSServer theServer) throws Exception;
        public void setCRClassName(String className) throws Exception;
        public void setSecurityManager(SecurityManager securityManager) throws 
Exception;
  }
  
  
  
  1.1                  
spyderMQ/src/java/org/spydermq/distributed/interfaces/DistributedTopicConnectionFactory.java
  
  Index: DistributedTopicConnectionFactory.java
  ===================================================================
   /*
   * spyderMQ, the OpenSource JMS implementation
   *
   * Distributable under GPL license.
   * See terms of license at gnu.org.
   */
  package org.spydermq.distributed.interfaces;
  
  import javax.jms.TopicConnection;
  import org.spydermq.security.SecurityManager;
  
  /**
   *    This is the interface for a distributed TopicConnectionFactory. 
   *      
   *    @author Norbert Lataille ([EMAIL PROTECTED])
   * 
   *    @version $Revision: 1.1 $
   */
  public interface DistributedTopicConnectionFactory
  {
        // Public --------------------------------------------------------
  
        public TopicConnection createTopicConnection() throws Exception;
      public TopicConnection createTopicConnection(String userName, String password) 
throws Exception;
        
        public void setServer(DistributedJMSServer theServer) throws Exception;
        public void setCRClassName(String className) throws Exception;
        public void setSecurityManager(SecurityManager securityManager) throws 
Exception;
  }