activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r499032 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java
Date Tue, 23 Jan 2007 14:29:27 GMT
Author: rajdavies
Date: Tue Jan 23 06:29:26 2007
New Revision: 499032

URL: http://svn.apache.org/viewvc?view=rev&rev=499032
Log:
applied patch for http://issues.apache.org/activemq/browse/AMQ-1077

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java?view=diff&rev=499032&r1=499031&r2=499032
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java
Tue Jan 23 06:29:26 2007
@@ -377,7 +377,8 @@
 				(destination!=null && destination.equals(sub.getDestination()) )
 			) {
 		        sendToActiveMQ(sub.getConsumerInfo().createRemoveCommand(), createResponseHandler(command));
-				return;
+				iter.remove();
+                return;
 			}
 		}
 



Mime
View raw message