From 84dbbc758b6eb308b993e9ede3c46cb4495fdffb Mon Sep 17 00:00:00 2001 From: Gary Tully Date: Thu, 26 Mar 2009 16:27:35 +0000 Subject: [PATCH] patch applied with thanks: AMQ-2178|https://issues.apache.org/activemq/browse/AMQ-2178 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@758721 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/activemq/state/ConnectionStateTracker.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java b/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java index 0ec8f59859..0c5dc3a853 100755 --- a/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java +++ b/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java @@ -279,7 +279,7 @@ public class ConnectionStateTracker extends CommandVisitorAdapter { return TRACKED_RESPONSE_MARKER; } - public Response processRemoveConsumer(ConsumerId id) { + public Response processRemoveConsumer(ConsumerId id, long lastDeliveredSequenceId) { if (id != null) { SessionId sessionId = id.getParentId(); if (sessionId != null) { @@ -311,7 +311,7 @@ public class ConnectionStateTracker extends CommandVisitorAdapter { return TRACKED_RESPONSE_MARKER; } - public Response processRemoveSession(SessionId id) { + public Response processRemoveSession(SessionId id, long lastDeliveredSequenceId) { if (id != null) { ConnectionId connectionId = id.getParentId(); if (connectionId != null) { @@ -331,7 +331,7 @@ public class ConnectionStateTracker extends CommandVisitorAdapter { return TRACKED_RESPONSE_MARKER; } - public Response processRemoveConnection(ConnectionId id) throws Exception { + public Response processRemoveConnection(ConnectionId id, long lastDeliveredSequenceId) throws Exception { if (id != null) { connectionStates.remove(id); }