[hornetq-commits] JBoss hornetq SVN: r9042 - in trunk: src/main/org/hornetq/core/server/impl and 1 other directory.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-04-01 10:28:35 -0400 (Thu, 01 Apr 2010)
New Revision: 9042

Modified:
   trunk/docs/user-manual/en/scheduled-messages.xml
   trunk/src/main/org/hornetq/core/server/impl/ScheduledDeliveryHandlerImpl.java
Log:
fix scheduled message

* do not schedule a message with a negative (or zero) delivery time and treat it as a regular unscheduled message

Modified: trunk/docs/user-manual/en/scheduled-messages.xml
===================================================================
--- trunk/docs/user-manual/en/scheduled-messages.xml	2010-04-01 10:13:11 UTC (rev 9041)
+++ trunk/docs/user-manual/en/scheduled-messages.xml	2010-04-01 14:28:35 UTC (rev 9042)
@@ -26,7 +26,7 @@
       <para>The property name used to identify a scheduled message is <literal
             >"_HQ_SCHED_DELIVERY"</literal> (or the constant <literal
             >Message.HDR_SCHEDULED_DELIVERY_TIME</literal>).</para>
-      <para>The specified value must be a <literal>long</literal> corresponding to the time the
+      <para>The specified value must be a positive <literal>long</literal> corresponding to the time the
          message must be delivered (in milliseconds). An example of sending a scheduled message
          using the JMS API is as follows.</para>
       <programlisting>

Modified: trunk/src/main/org/hornetq/core/server/impl/ScheduledDeliveryHandlerImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/server/impl/ScheduledDeliveryHandlerImpl.java	2010-04-01 10:13:11 UTC (rev 9041)
+++ trunk/src/main/org/hornetq/core/server/impl/ScheduledDeliveryHandlerImpl.java	2010-04-01 14:28:35 UTC (rev 9042)
@@ -52,7 +52,7 @@
    {
       long deliveryTime = ref.getScheduledDeliveryTime();
 
-      if (deliveryTime != 0 && scheduledExecutor != null)
+      if (deliveryTime > 0 && scheduledExecutor != null)
       {
          if (ScheduledDeliveryHandlerImpl.trace)
          {