fix for: https://issues.apache.org/jira/browse/AMQNET-310
Project: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/commit/836e216d Tree: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/tree/836e216d Diff: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/diff/836e216d Branch: refs/heads/1.5.x Commit: 836e216d7ef8e1cc21bf4679b80ff9e2ec0a3083 Parents: ce876d0 Author: Timothy A. Bish <tab...@apache.org> Authored: Sun Jan 23 16:45:41 2011 +0000 Committer: Timothy A. Bish <tab...@apache.org> Committed: Sun Jan 23 16:45:41 2011 +0000 ---------------------------------------------------------------------- src/main/csharp/Session.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/blob/836e216d/src/main/csharp/Session.cs ---------------------------------------------------------------------- diff --git a/src/main/csharp/Session.cs b/src/main/csharp/Session.cs index f37d738..6770283 100755 --- a/src/main/csharp/Session.cs +++ b/src/main/csharp/Session.cs @@ -784,7 +784,7 @@ namespace Apache.NMS.Stomp lock(this.consumers.SyncRoot) { - foreach(MessageConsumer consumer in this.consumers) + foreach(MessageConsumer consumer in this.consumers.Values) { consumer.InProgressClearRequired(); ThreadPool.QueueUserWorkItem(ClearMessages, consumer);
