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

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)