activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r758721 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
Date Thu, 26 Mar 2009 16:27:45 GMT
Author: gtully
Date: Thu Mar 26 16:27:35 2009
New Revision: 758721

URL: http://svn.apache.org/viewvc?rev=758721&view=rev
Log:
patch applied with thanks: AMQ-2178|https://issues.apache.org/activemq/browse/AMQ-2178

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java?rev=758721&r1=758720&r2=758721&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
Thu Mar 26 16:27:35 2009
@@ -279,7 +279,7 @@
         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 @@
         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 @@
         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);
         }



Mime
View raw message