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

[jBoss CVS Development]

  User: hiram   
  Date: 00/12/23 07:48:20

  Modified:    src/java/org/spydermq/distributed/interfaces
                        ConnectionReceiver.java DistributedJMSServer.java
  Log:
  These changes were done to add the following features:
  The selector is now evaluated at the server side.
  The infrastructure has been laid for durable topic subscriptions.
  The QueueBrowser has been implemented.
  Queues now can have a Selector.
  
  Revision  Changes    Path
  1.6       +7 -11     
spyderMQ/src/java/org/spydermq/distributed/interfaces/ConnectionReceiver.java
  
  Index: ConnectionReceiver.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/interfaces/ConnectionReceiver.java,v
  retrieving revision 1.5
  retrieving revision 1.6
  diff -u -r1.5 -r1.6
  --- ConnectionReceiver.java   2000/12/12 05:58:48     1.5
  +++ ConnectionReceiver.java   2000/12/23 15:48:19     1.6
  @@ -6,29 +6,25 @@
    */
   package org.spydermq.distributed.interfaces;
   
  -import javax.jms.Destination;
  -import org.spydermq.SpyMessage;
  -import org.spydermq.SpyConnection;
   import org.spydermq.SpyDestination;
  +import org.spydermq.ReceiveRequest;
   
   /**
    *   This interface implements one callback for the Connection object
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
  + *   @author Hiram Chirino ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.5 $
  + *   @version $Revision: 1.6 $
    */
  -
   public interface ConnectionReceiver 
   {
  -     // Public --------------------------------------------------------
  -
  -     //A message has arrived for the Connection 
  -     public void receive(SpyDestination dest,SpyMessage mes) throws Exception;      
 
  -     //Many messages have arrived for this Connection 
  -     public void receiveMultiple(SpyDestination 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;   
  +     //A message has arrived for the Connection 
  +     public void receive(ReceiveRequest messages[]) throws Exception;
  +     
   }
  
  
  
  1.7       +10 -12    
spyderMQ/src/java/org/spydermq/distributed/interfaces/DistributedJMSServer.java
  
  Index: DistributedJMSServer.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/interfaces/DistributedJMSServer.java,v
  retrieving revision 1.6
  retrieving revision 1.7
  diff -u -r1.6 -r1.7
  --- DistributedJMSServer.java 2000/12/19 06:43:39     1.6
  +++ DistributedJMSServer.java 2000/12/23 15:48:19     1.7
  @@ -16,29 +16,27 @@
   import org.spydermq.SpyMessage;
   import org.spydermq.SpyDestination;
   import org.spydermq.SpyDistributedConnection;
  -import org.spydermq.SpyAcknowledgementItem;
  -
  -
   import org.spydermq.TransactionRequest;
  +import org.spydermq.AcknowledgementRequest;
   
   public interface DistributedJMSServer
   {
  -     // Public --------------------------------------------------------
  -
        public String getID() throws Exception;
        public TemporaryTopic getTemporaryTopic(SpyDistributedConnection dc) throws 
Exception;
        public TemporaryQueue getTemporaryQueue(SpyDistributedConnection dc) throws 
Exception;
        public void connectionClosing(SpyDistributedConnection dc) throws Exception;
        public void checkID(String ID) throws Exception;
        public void setSpyDistributedConnection(org.spydermq.SpyDistributedConnection 
newSpyDistributedConnection) throws Exception;
  -     public void acknowledge(SpyDistributedConnection dc, SpyAcknowledgementItem 
item) throws Exception;     
  -     public void addMessage(SpyDistributedConnection dc, SpyMessage message) throws 
Exception;       
  -     public void connectionListening(SpyDistributedConnection dc, boolean 
mode,Destination dest) throws Exception;   
  +     public void addMessage(SpyDistributedConnection dc, SpyMessage message) throws 
Exception;               
        public Queue createQueue(SpyDistributedConnection dc, String dest) throws 
Exception;    
        public Topic createTopic(SpyDistributedConnection dc, String dest) throws 
Exception;    
        public void deleteTemporaryDestination(SpyDistributedConnection dc, 
SpyDestination dest) throws Exception;      
  -     public SpyMessage queueReceive(SpyDistributedConnection dc, Queue queue, long 
wait) throws Exception;   
  -     public void subscribe(SpyDistributedConnection dc, Destination dest) throws 
Exception;          
  -     public void unsubscribe(SpyDistributedConnection dc, Destination dest) throws 
Exception;
  -     public void transact(SpyDistributedConnection dc, TransactionRequest t) throws 
Exception;
  +     public void transact(SpyDistributedConnection dc, TransactionRequest t) throws 
Exception;       
  +     public void acknowledge(SpyDistributedConnection dc, AcknowledgementRequest 
item) throws Exception;
  +     public SpyMessage[] browse(SpyDistributedConnection dc, Destination dest, 
String selector) throws Exception;
  +     public void listenerChange(SpyDistributedConnection dc, int subscriberId, 
boolean state) throws Exception;
  +     public SpyMessage receive(SpyDistributedConnection dc, int subscriberId, long 
wait) throws Exception;
  +     public void setEnabled(SpyDistributedConnection dc, boolean enabled) throws 
Exception;
  +     public void subscribe(SpyDistributedConnection dc, org.spydermq.Subscription 
s) throws Exception;
  +     public void unsubscribe(SpyDistributedConnection dc, int subscriptionId ) 
throws Exception;
   }