You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2007/01/23 15:29:27 UTC
svn commit: r499032 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java
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;
}
}