[jboss-cvs] jboss-jms/src/main/org/jboss/jms/delegate ...

[Timothy Fox]

  User: timfox  
  Date: 06/07/17 13:14:45

  Modified:    src/main/org/jboss/jms/delegate  SessionDelegate.java
  Log:
  Many changes including implementation of prefetch, SEDAisation of server, changing of recovery
  
  Revision  Changes    Path
  1.31      +9 -4      jboss-jms/src/main/org/jboss/jms/delegate/SessionDelegate.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: SessionDelegate.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/jms/delegate/SessionDelegate.java,v
  retrieving revision 1.30
  retrieving revision 1.31
  diff -u -b -r1.30 -r1.31
  --- SessionDelegate.java	11 Mar 2006 14:26:18 -0000	1.30
  +++ SessionDelegate.java	17 Jul 2006 17:14:45 -0000	1.31
  @@ -22,6 +22,7 @@
   package org.jboss.jms.delegate;
   
   import java.io.Serializable;
  +import java.util.List;
   
   import javax.jms.JMSException;
   import javax.jms.MessageListener;
  @@ -42,9 +43,9 @@
    * 
    * @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
    * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
  - * @version <tt>$Revision: 1.30 $</tt>
  + * @version <tt>$Revision: 1.31 $</tt>
    *
  - * $Id: SessionDelegate.java,v 1.30 2006/03/11 14:26:18 timfox Exp $
  + * $Id: SessionDelegate.java,v 1.31 2006/07/17 17:14:45 timfox Exp $
    */
   public interface SessionDelegate extends SessionEndpoint
   {   
  @@ -64,9 +65,9 @@
      
      TextMessageProxy createTextMessage(String text) throws JMSException;
      
  -   void preDeliver(long messageID, int receiverID) throws JMSException;
  +   void preDeliver(MessageProxy proxy, int consumerID) throws JMSException;
      
  -   void postDeliver(long messageID, int receiverID) throws JMSException;
  +   void postDeliver(MessageProxy proxy, int consumerID) throws JMSException;
      
      MessageListener getMessageListener() throws JMSException;
      
  @@ -88,7 +89,11 @@
      
      void recover() throws JMSException;
      
  +   void redeliver(List ackInfos) throws JMSException;
  +   
      ProducerDelegate createProducerDelegate(JBossDestination destination) throws JMSException;
   
  +   void acknowledgeAll() throws JMSException;
  +
   
   }