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

[jBoss CVS Development]

  User: norbert 
  Date: 00/06/14 21:02:28

  Modified:    src/java/org/spydermq/distributed/server
                        ConnectionReceiverRMIImpl.java
                        ConnectionReceiverRMI.java
  Log:
  Very first step for the Optimized Invocation Layer
  It only works for the ConnectionReceiver object
  
  Revision  Changes    Path
  1.8       +3 -3      
spyderMQ/src/java/org/spydermq/distributed/server/ConnectionReceiverRMIImpl.java
  
  Index: ConnectionReceiverRMIImpl.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/server/ConnectionReceiverRMIImpl.java,v
  retrieving revision 1.7
  retrieving revision 1.8
  diff -u -r1.7 -r1.8
  --- ConnectionReceiverRMIImpl.java    2000/06/14 19:16:52     1.7
  +++ ConnectionReceiverRMIImpl.java    2000/06/15 04:02:28     1.8
  @@ -29,7 +29,7 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.7 $
  + *   @version $Revision: 1.8 $
    */
   public class ConnectionReceiverRMIImpl extends UnicastRemoteObject implements 
ConnectionReceiverRMI
   {
  @@ -56,7 +56,7 @@
        }
        
        //A message has arrived for this Connection, We have to dispatch it to the 
sessions
  -    public void receive(Destination dest,SpyMessage mes) throws JMSException
  +    public void receive(SpyDestination dest,SpyMessage mes) throws JMSException
        {
                if (closed) throw new IllegalStateException("The connection is 
closed");
                
  @@ -132,7 +132,7 @@
                }
        } 
   
  -     public void receiveMultiple(Destination dest,SpyMessage mes[]) throws 
JMSException
  +     public void receiveMultiple(SpyDestination dest,SpyMessage mes[]) throws 
JMSException
        {
                for(int i=0;i<mes.length;i++) {
                        receive(dest,mes[i]);
  
  
  
  1.2       +3 -3      
spyderMQ/src/java/org/spydermq/distributed/server/ConnectionReceiverRMI.java
  
  Index: ConnectionReceiverRMI.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/server/ConnectionReceiverRMI.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- ConnectionReceiverRMI.java        2000/05/31 18:10:16     1.1
  +++ ConnectionReceiverRMI.java        2000/06/15 04:02:28     1.2
  @@ -19,16 +19,16 @@
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.1 $
  + *   @version $Revision: 1.2 $
    */
   public interface ConnectionReceiverRMI extends ConnectionReceiver, Remote
   {
        // Public --------------------------------------------------------
   
        //A message has arrived for the Connection 
  -    public void receive(Destination b,SpyMessage c) throws RemoteException, 
JMSException;
  +    public void receive(SpyDestination b,SpyMessage c) throws RemoteException, 
JMSException;
        //Messages have arrived for the Connection 
  -     public void receiveMultiple(Destination dest,SpyMessage mes[]) throws 
RemoteException, JMSException;
  +     public void receiveMultiple(SpyDestination dest,SpyMessage mes[]) throws 
RemoteException, JMSException;
        //One TemporaryDestination has been deleted
        public void deleteTemporaryDestination(SpyDestination dest) throws 
RemoteException, JMSException;
   }