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

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2009-10-29 06:30:59 -0400 (Thu, 29 Oct 2009)
New Revision: 8166

Modified:
   trunk/src/main/org/hornetq/core/remoting/impl/wireformat/SessionForceConsumerDelivery.java
   trunk/src/main/org/hornetq/core/server/impl/ServerSessionImpl.java
Log:
fixed session force consumer delivery packet

Modified: trunk/src/main/org/hornetq/core/remoting/impl/wireformat/SessionForceConsumerDelivery.java
===================================================================
--- trunk/src/main/org/hornetq/core/remoting/impl/wireformat/SessionForceConsumerDelivery.java	2009-10-29 10:19:25 UTC (rev 8165)
+++ trunk/src/main/org/hornetq/core/remoting/impl/wireformat/SessionForceConsumerDelivery.java	2009-10-29 10:30:59 UTC (rev 8166)
@@ -100,11 +100,6 @@
       return super.equals(other) && this.consumerID == r.consumerID && this.sequence == r.sequence;
    }
 
-   public final boolean isRequiresConfirmations()
-   {
-      return false;
-   }
-
    // Package protected ---------------------------------------------
 
    // Protected -----------------------------------------------------

Modified: trunk/src/main/org/hornetq/core/server/impl/ServerSessionImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/server/impl/ServerSessionImpl.java	2009-10-29 10:19:25 UTC (rev 8165)
+++ trunk/src/main/org/hornetq/core/server/impl/ServerSessionImpl.java	2009-10-29 10:30:59 UTC (rev 8166)
@@ -636,6 +636,8 @@
       {
          log.error("Failed to query consumer deliveries", e);
       }
+      
+      sendResponse(message, null, false, false);
    }
 
    public void handleAcknowledge(final SessionAcknowledgeMessage packet)