Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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
This commit is contained in:
Gary Tully 2009-03-26 16:27:35 +00:00
parent 132f662209
commit 84dbbc758b
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
View File

@ -279,7 +279,7 @@ public class ConnectionStateTracker extends CommandVisitorAdapter {
return TRACKED_RESPONSE_MARKER; return TRACKED_RESPONSE_MARKER;
} }
public Response processRemoveConsumer(ConsumerId id) { public Response processRemoveConsumer(ConsumerId id, long lastDeliveredSequenceId) {
if (id != null) { if (id != null) {
SessionId sessionId = id.getParentId(); SessionId sessionId = id.getParentId();
if (sessionId != null) { if (sessionId != null) {
@ -311,7 +311,7 @@ public class ConnectionStateTracker extends CommandVisitorAdapter {
return TRACKED_RESPONSE_MARKER; return TRACKED_RESPONSE_MARKER;
} }
public Response processRemoveSession(SessionId id) { public Response processRemoveSession(SessionId id, long lastDeliveredSequenceId) {
if (id != null) { if (id != null) {
ConnectionId connectionId = id.getParentId(); ConnectionId connectionId = id.getParentId();
if (connectionId != null) { if (connectionId != null) {
@ -331,7 +331,7 @@ public class ConnectionStateTracker extends CommandVisitorAdapter {
return TRACKED_RESPONSE_MARKER; return TRACKED_RESPONSE_MARKER;
} }
public Response processRemoveConnection(ConnectionId id) throws Exception { public Response processRemoveConnection(ConnectionId id, long lastDeliveredSequenceId) throws Exception {
if (id != null) { if (id != null) {
connectionStates.remove(id); connectionStates.remove(id);
} }