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

[jBoss CVS Development]

  User: hiram   
  Date: 00/12/18 22:43:39

  Modified:    src/java/org/spydermq/distributed/interfaces
                        DistributedJMSServer.java
                        DistributedConnectionFactory.java
  Log:
  Add XA support!  Well.. I haven't tested very much but it's a start.
  
  Revision  Changes    Path
  1.6       +5 -4      
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.5
  retrieving revision 1.6
  diff -u -r1.5 -r1.6
  --- DistributedJMSServer.java 2000/12/12 05:58:49     1.5
  +++ DistributedJMSServer.java 2000/12/19 06:43:39     1.6
  @@ -17,8 +17,10 @@
   import org.spydermq.SpyDestination;
   import org.spydermq.SpyDistributedConnection;
   import org.spydermq.SpyAcknowledgementItem;
  -import org.spydermq.Transaction;
   
  +
  +import org.spydermq.TransactionRequest;
  +
   public interface DistributedJMSServer
   {
        // Public --------------------------------------------------------
  @@ -36,8 +38,7 @@
        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 transact(SpyDistributedConnection dc, Transaction t) 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;
   }
  
  
  
  1.2       +12 -0     
spyderMQ/src/java/org/spydermq/distributed/interfaces/DistributedConnectionFactory.java
  
  Index: DistributedConnectionFactory.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/spyderMQ/src/java/org/spydermq/distributed/interfaces/DistributedConnectionFactory.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- DistributedConnectionFactory.java 2000/12/12 05:58:48     1.1
  +++ DistributedConnectionFactory.java 2000/12/19 06:43:39     1.2
  @@ -12,6 +12,9 @@
   import org.spydermq.server.JMSServer;
   import org.spydermq.security.SecurityManager;
   
  +import javax.jms.XAQueueConnection;
  +import javax.jms.XATopicConnection;
  +
   public interface DistributedConnectionFactory
   {
   
  @@ -25,4 +28,13 @@
        public TopicConnection createTopicConnection(String userName, String password) 
throws Exception;        
        public void setConnectionReceiverClassName(String className) throws Exception;
   
  +     // Public --------------------------------------------------------
  +
  +     public XAQueueConnection createXAQueueConnection() throws Exception;
  +
  +     public XAQueueConnection createXAQueueConnection(String userName, String 
password) throws Exception;
  +
  +     public XATopicConnection createXATopicConnection() throws Exception;
  +
  +     public XATopicConnection createXATopicConnection(String userName, String 
password) throws Exception;
   }