[jBoss-Dev] CVS update: spyderMQ/src/java/org/spyderMQSpyMessageProducer.java

[jBoss CVS Development]

  User: norbert 
  Date: 00/05/30 16:04:07

  Modified:    src/java/org/spyderMQ SpyMessageProducer.java
  Log:
  default values for TTL / Priority / persistance
  
  Revision  Changes    Path
  1.8       +12 -8     spyderMQ/src/java/org/spyderMQ/SpyMessageProducer.java
  
  Index: SpyMessageProducer.java
  ===================================================================
  RCS file: 
/products/cvs/ejboss/spyderMQ/src/java/org/spyderMQ/SpyMessageProducer.java,v
  retrieving revision 1.7
  retrieving revision 1.8
  diff -u -r1.7 -r1.8
  --- SpyMessageProducer.java   2000/05/15 19:40:17     1.7
  +++ SpyMessageProducer.java   2000/05/30 23:04:07     1.8
  @@ -9,13 +9,14 @@
   import javax.jms.MessageProducer;
   import javax.jms.JMSException;
   import javax.jms.DeliveryMode;
  +import javax.jms.Message;
   
   /**
    *   This class implements javax.jms.MessageProducer
    *      
    *   @author Norbert Lataille ([EMAIL PROTECTED])
    * 
  - *   @version $Revision: 1.7 $
  + *   @version $Revision: 1.8 $
    */
   public class SpyMessageProducer 
        implements MessageProducer
  @@ -26,7 +27,7 @@
        private boolean disableTS = false;
        protected int defaultDeliveryMode = DeliveryMode.NON_PERSISTENT;
        protected int defaultPriority=4;
  -     protected int defaultTTL=64;
  +     protected int defaultTTL=0;
   
        // Public --------------------------------------------------------
        
  @@ -52,8 +53,9 @@
   
       public void setDeliveryMode(int deli) throws JMSException
        {
  -             if (deli!=DeliveryMode.NON_PERSISTENT&&deli!=DeliveryMode.PERSISTENT) 
throw new JMSException("Bad DeliveryMode value");
  -             defaultDeliveryMode=deli;
  +             if (deli==Message.DEFAULT_DELIVERY_MODE) 
defaultDeliveryMode=DeliveryMode.NON_PERSISTENT;
  +             else if 
(deli!=DeliveryMode.NON_PERSISTENT&&deli!=DeliveryMode.PERSISTENT) throw new 
JMSException("Bad DeliveryMode value");
  +             else defaultDeliveryMode=deli;
        }
        
       public int getDeliveryMode() throws JMSException
  @@ -63,8 +65,9 @@
   
       public void setPriority(int pri) throws JMSException
        {
  -             if (pri<0||pri>9) throw new JMSException("Bad priority value");
  -             defaultPriority=pri;
  +             if (pri==Message.DEFAULT_PRIORITY) defaultPriority=4;
  +             else if (pri<0||pri>9) throw new JMSException("Bad priority value");
  +             else defaultPriority=pri;
        }
   
       public int getPriority() throws JMSException
  @@ -74,8 +77,9 @@
   
       public void setTimeToLive(int timeToLive) throws JMSException
        {
  -             if (timeToLive<0) throw new JMSException("Bad TTL value");
  -             defaultTTL=timeToLive;
  +             if (timeToLive==Message.DEFAULT_TIME_TO_LIVE) timeToLive=0;
  +             else if (timeToLive<0) throw new JMSException("Bad TimeToLive value");
  +             else defaultTTL=timeToLive;
        }
      
       public int getTimeToLive() throws JMSException