[jboss-cvs] jboss-jms/src/main/org/jboss/jms/server/subscription ...

[Timothy Fox]

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

  Modified:    src/main/org/jboss/jms/server/subscription  
                        DurableSubscription.java Subscription.java
  Log:
  Many changes including implementation of prefetch, SEDAisation of server, changing of recovery
  
  Revision  Changes    Path
  1.4       +7 -4      jboss-jms/src/main/org/jboss/jms/server/subscription/DurableSubscription.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: DurableSubscription.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/jms/server/subscription/DurableSubscription.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -b -r1.3 -r1.4
  --- DurableSubscription.java	27 Jun 2006 19:44:39 -0000	1.3
  +++ DurableSubscription.java	17 Jul 2006 17:14:46 -0000	1.4
  @@ -28,14 +28,16 @@
   import org.jboss.messaging.core.plugin.contract.MessageStore;
   import org.jboss.messaging.core.plugin.contract.PersistenceManager;
   
  +import EDU.oswego.cs.dl.util.concurrent.QueuedExecutor;
  +
   /**
    * 
    * A DurableSubscription.
    * 
    * @author <a href="tim.fox at jboss.com">Tim Fox</a>
  - * @version $Revision: 1.3 $
  + * @version $Revision: 1.4 $
    *
  - * $Id: DurableSubscription.java,v 1.3 2006/06/27 19:44:39 timfox Exp $
  + * $Id: DurableSubscription.java,v 1.4 2006/07/17 17:14:46 timfox Exp $
    */
   public class DurableSubscription extends Subscription
   {
  @@ -45,10 +47,11 @@
      
      public DurableSubscription(long id, Topic topic, 
            MessageStore ms, PersistenceManager pm, MemoryManager mm, 
  -         int fullSize, int pageSize, int downCacheSize, Selector selector, boolean isNoLocal,
  +         int fullSize, int pageSize, int downCacheSize, QueuedExecutor executor,
  +         Selector selector, boolean isNoLocal,
            String name, String clientID)
      {
  -      super(id, topic, ms, pm, mm, true, fullSize, pageSize, downCacheSize, selector, isNoLocal);
  +      super(id, topic, ms, pm, mm, true, fullSize, pageSize, downCacheSize, executor, selector, isNoLocal);
         this.name = name;
         this.clientID = clientID;
      }
  
  
  
  1.4       +10 -6     jboss-jms/src/main/org/jboss/jms/server/subscription/Subscription.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: Subscription.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/jms/server/subscription/Subscription.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -b -r1.3 -r1.4
  --- Subscription.java	27 Jun 2006 19:44:39 -0000	1.3
  +++ Subscription.java	17 Jul 2006 17:14:46 -0000	1.4
  @@ -28,14 +28,16 @@
   import org.jboss.messaging.core.plugin.contract.MessageStore;
   import org.jboss.messaging.core.plugin.contract.PersistenceManager;
   
  +import EDU.oswego.cs.dl.util.concurrent.QueuedExecutor;
  +
   /**
    * 
    * A Subscription.
    * 
    * @author <a href="tim.fox at jboss.com">Tim Fox</a>
  - * @version $Revision: 1.3 $
  + * @version $Revision: 1.4 $
    *
  - * $Id: Subscription.java,v 1.3 2006/06/27 19:44:39 timfox Exp $
  + * $Id: Subscription.java,v 1.4 2006/07/17 17:14:46 timfox Exp $
    */
   public class Subscription extends CoreSubscription
   {
  @@ -43,16 +45,18 @@
      
      public Subscription(long id, Topic topic, 
            MessageStore ms, PersistenceManager pm, MemoryManager mm,
  -         int fullSize, int pageSize, int downCacheSize, Selector selector, boolean isNoLocal)
  +         int fullSize, int pageSize, int downCacheSize,
  +         QueuedExecutor executor, Selector selector, boolean isNoLocal)
      {
  -      this(id, topic, ms, pm, mm, false, fullSize, pageSize, downCacheSize, selector, isNoLocal);
  +      this(id, topic, ms, pm, mm, false, fullSize, pageSize, downCacheSize, executor, selector, isNoLocal);
      }
      
      protected Subscription(long id, Topic topic, 
            MessageStore ms, PersistenceManager pm, MemoryManager mm, boolean recoverable,
  -         int fullSize, int pageSize, int downCacheSize, Selector selector, boolean isNoLocal)
  +         int fullSize, int pageSize, int downCacheSize,
  +         QueuedExecutor executor, Selector selector, boolean isNoLocal)
      {
  -      super(id, topic, ms, pm, mm, recoverable, fullSize, pageSize, downCacheSize, selector);
  +      super(id, topic, ms, pm, mm, recoverable, fullSize, pageSize, downCacheSize, executor, selector);
         this.isNoLocal = isNoLocal;
      }