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)
Show replies by date