[jboss-cvs] jboss-jms/src/main/org/jboss/messaging/core/message ...

[Timothy Fox]

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

  Modified:    src/main/org/jboss/messaging/core/message  
                        MessageSupport.java RoutableSupport.java
  Log:
  Many changes including implementation of prefetch, SEDAisation of server, changing of recovery
  
  Revision  Changes    Path
  1.28      +8 -4      jboss-jms/src/main/org/jboss/messaging/core/message/MessageSupport.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: MessageSupport.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/messaging/core/message/MessageSupport.java,v
  retrieving revision 1.27
  retrieving revision 1.28
  diff -u -b -r1.27 -r1.28
  --- MessageSupport.java	19 Jun 2006 15:16:07 -0000	1.27
  +++ MessageSupport.java	17 Jul 2006 17:14:47 -0000	1.28
  @@ -29,6 +29,7 @@
   import java.io.Serializable;
   import java.util.Map;
   
  +import org.jboss.logging.Logger;
   import org.jboss.messaging.core.Message;
   import org.jboss.serial.io.JBossObjectInputStream;
   import org.jboss.serial.io.JBossObjectOutputStream;
  @@ -39,9 +40,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.27 $</tt>
  + * @version <tt>$Revision: 1.28 $</tt>
    *
  - * $Id: MessageSupport.java,v 1.27 2006/06/19 15:16:07 timfox Exp $
  + * $Id: MessageSupport.java,v 1.28 2006/07/17 17:14:47 timfox Exp $
    */
   public abstract class MessageSupport extends RoutableSupport implements Message
   {
  @@ -49,6 +50,9 @@
   
      private static final long serialVersionUID = -4474943687659785336L;
      
  +   private static final Logger log = Logger.getLogger(MessageSupport.class);
  +
  +   
      // Attributes ----------------------------------------------------
      
      // Must be hidden from subclasses
  
  
  
  1.28      +7 -2      jboss-jms/src/main/org/jboss/messaging/core/message/RoutableSupport.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: RoutableSupport.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/messaging/core/message/RoutableSupport.java,v
  retrieving revision 1.27
  retrieving revision 1.28
  diff -u -b -r1.27 -r1.28
  --- RoutableSupport.java	26 Jun 2006 18:41:22 -0000	1.27
  +++ RoutableSupport.java	17 Jul 2006 17:14:47 -0000	1.28
  @@ -41,9 +41,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.27 $</tt>
  + * @version <tt>$Revision: 1.28 $</tt>
    *
  - * $Id: RoutableSupport.java,v 1.27 2006/06/26 18:41:22 timfox Exp $
  + * $Id: RoutableSupport.java,v 1.28 2006/07/17 17:14:47 timfox Exp $
    */
   public abstract class RoutableSupport implements Routable, Externalizable
   {
  @@ -468,6 +468,11 @@
         deliveryCount++;      
      }
      
  +   public void decrementDeliveryCount()
  +   {
  +      deliveryCount--;
  +   }
  +   
      public void setDeliveryCount(int deliveryCount)
      {
         this.deliveryCount = deliveryCount;