svn commit: r886998 [2/14] - in /qpid/trunk: ./ qpid/dotnet/Qpid.Buffer.Tests/ qpid/dotnet/Qpid.Buffer.Tests/Properties/ qpid/dotnet/Qpid.Buffer/ qpid/dotnet/Qpid.Client.Tests/BrokerDetails/ qpid/dotnet/Qpid.Client.Tests/Channel/ qpid/dotnet/Qpid.Clien...

[ai...@apache.org]

Modified: qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Channel/ChannelMessageCreationTests.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Channel/ChannelMessageCreationTests.cs?rev=886998&r1=886997&r2=886998&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Channel/ChannelMessageCreationTests.cs (original)
+++ qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Channel/ChannelMessageCreationTests.cs Thu Dec  3 23:55:48 2009
@@ -1,79 +1,79 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-using System;
-
-using log4net;
-using NUnit.Framework;
-using Apache.Qpid.Client;
-using Apache.Qpid.Client.Message;
-using Apache.Qpid.Messaging;
-
-namespace Apache.Qpid.Client.Tests.Channel
-{
-   /// <summary>
-   /// Test that channels can create messages correctly
-   /// </summary>
-   [TestFixture]
-   public class ChannelMessageCreationTests
-   {
-      [Test]
-      public void CanCreateTextMessage()
-      {
-         IChannel channel = AmqChannel.CreateDisconnectedChannel();
-         ITextMessage msg = channel.CreateTextMessage();
-         Assert.IsNotNull(msg);
-      }
-      [Test]
-      public void CanCreateTextMessageWithContent()
-      {
-         IChannel channel = AmqChannel.CreateDisconnectedChannel();
-         const string CONTENT = "1234567890";
-         ITextMessage msg = channel.CreateTextMessage(CONTENT);
-         Assert.IsNotNull(msg);
-         Assert.AreEqual(CONTENT, msg.Text);
-      }
-      [Test]
-      public void CanCreateBytesMessage()
-      {
-         IChannel channel = AmqChannel.CreateDisconnectedChannel();
-         IBytesMessage msg = channel.CreateBytesMessage();
-         Assert.IsNotNull(msg);
-      }
-      [Test]
-      public void CanCreateMessage()
-      {
-         IChannel channel = AmqChannel.CreateDisconnectedChannel();
-         IMessage msg = channel.CreateMessage();
-         Assert.IsNotNull(msg);
-      }
-      [Test]
-      public void CanCreateMessageFromMimeType()
-      {
-         IChannel channel = AmqChannel.CreateDisconnectedChannel();
-         IMessage msg = channel.CreateMessage("text/xml");
-         Assert.IsNotNull(msg);
-         Assert.IsInstanceOfType(typeof(ITextMessage), msg);
-      }
-   }
-} // namespace Apache.Qpid.Client.Tests.Channel
-
-
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+using System;
+
+using log4net;
+using NUnit.Framework;
+using Apache.Qpid.Client;
+using Apache.Qpid.Client.Message;
+using Apache.Qpid.Messaging;
+
+namespace Apache.Qpid.Client.Tests.Channel
+{
+   /// <summary>
+   /// Test that channels can create messages correctly
+   /// </summary>
+   [TestFixture]
+   public class ChannelMessageCreationTests
+   {
+      [Test]
+      public void CanCreateTextMessage()
+      {
+         IChannel channel = AmqChannel.CreateDisconnectedChannel();
+         ITextMessage msg = channel.CreateTextMessage();
+         Assert.IsNotNull(msg);
+      }
+      [Test]
+      public void CanCreateTextMessageWithContent()
+      {
+         IChannel channel = AmqChannel.CreateDisconnectedChannel();
+         const string CONTENT = "1234567890";
+         ITextMessage msg = channel.CreateTextMessage(CONTENT);
+         Assert.IsNotNull(msg);
+         Assert.AreEqual(CONTENT, msg.Text);
+      }
+      [Test]
+      public void CanCreateBytesMessage()
+      {
+         IChannel channel = AmqChannel.CreateDisconnectedChannel();
+         IBytesMessage msg = channel.CreateBytesMessage();
+         Assert.IsNotNull(msg);
+      }
+      [Test]
+      public void CanCreateMessage()
+      {
+         IChannel channel = AmqChannel.CreateDisconnectedChannel();
+         IMessage msg = channel.CreateMessage();
+         Assert.IsNotNull(msg);
+      }
+      [Test]
+      public void CanCreateMessageFromMimeType()
+      {
+         IChannel channel = AmqChannel.CreateDisconnectedChannel();
+         IMessage msg = channel.CreateMessage("text/xml");
+         Assert.IsNotNull(msg);
+         Assert.IsInstanceOfType(typeof(ITextMessage), msg);
+      }
+   }
+} // namespace Apache.Qpid.Client.Tests.Channel
+
+

Propchange: qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Channel/ChannelMessageCreationTests.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Messages/MessageFactoryRegistryTests.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Messages/MessageFactoryRegistryTests.cs?rev=886998&r1=886997&r2=886998&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Messages/MessageFactoryRegistryTests.cs (original)
+++ qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Messages/MessageFactoryRegistryTests.cs Thu Dec  3 23:55:48 2009
@@ -1,114 +1,114 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-using System;
-
-using log4net;
-using NUnit.Framework;
-using Apache.Qpid.Messaging;
-using Apache.Qpid.Client.Message;
-
-namespace Apache.Qpid.Client.Tests.Messages
-{
-   /// <summary>
-   /// Ensure a factory creates messages correctly
-   /// </summary>
-   [TestFixture]
-   public class MessageFactoryRegistryTests
-   {
-      const string TEXT_PLAIN = "text/plain";
-      const string TEXT_XML = "text/xml";
-      const string OCTET_STREAM = "application/octet-stream";
-
-      /// <summary>
-      /// Check default registry can create text/plain messages
-      /// </summary>
-      [Test]
-      public void CanCreateTextPlain()
-      {
-         MessageFactoryRegistry registry = 
-            MessageFactoryRegistry.NewDefaultRegistry();
-
-         IMessage message = registry.CreateMessage(TEXT_PLAIN);
-         Assert.IsNotNull(message);
-         Assert.AreEqual(TEXT_PLAIN, message.ContentType);
-         Assert.IsInstanceOfType(typeof(QpidTextMessage), message);
-      }
-      /// <summary>
-      /// Check default registry can create text/xml messages
-      /// </summary>
-      [Test]
-      public void CanCreateTextXml()
-      {
-         MessageFactoryRegistry registry =
-            MessageFactoryRegistry.NewDefaultRegistry();
-
-         IMessage message = registry.CreateMessage(TEXT_XML);
-         Assert.IsNotNull(message);
-         Assert.AreEqual(TEXT_XML, message.ContentType);
-         Assert.IsInstanceOfType(typeof(QpidTextMessage), message);
-      }
-      /// <summary>
-      /// Check default registry can create application/octet-stream messages
-      /// </summary>
-      [Test]
-      public void CanCreateBinary()
-      {
-         MessageFactoryRegistry registry =
-            MessageFactoryRegistry.NewDefaultRegistry();
-
-         IMessage message = registry.CreateMessage(OCTET_STREAM);
-         Assert.IsNotNull(message);
-         Assert.AreEqual(OCTET_STREAM, message.ContentType);
-         Assert.IsInstanceOfType(typeof(QpidBytesMessage), message);
-      }
-      /// <summary>
-      /// Check default registry can create messages for unknown types
-      /// </summary>
-      [Test]
-      public void CanCreateUnknownType()
-      {
-         MessageFactoryRegistry registry =
-            MessageFactoryRegistry.NewDefaultRegistry();
-
-         const string OTHER = "application/unknown";
-         IMessage message = registry.CreateMessage(OTHER);
-         Assert.IsNotNull(message);
-         Assert.AreEqual(OTHER, message.ContentType);
-         Assert.IsInstanceOfType(typeof(QpidBytesMessage), message);
-      }
-      /// <summary>
-      /// Check that text messages default to UTF-8 encoding
-      /// </summary>
-      [Test]
-      public void TextMessagesDefaultToUTF8Encoding()
-      {
-         MessageFactoryRegistry registry =
-            MessageFactoryRegistry.NewDefaultRegistry();
-
-         IMessage message = registry.CreateMessage(TEXT_PLAIN);
-         Assert.AreEqual("utf-8", message.ContentEncoding.ToLower());
-      }
-
-   }
-} // namespace Apache.Qpid.Client.Tests.Messages
-
-
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+using System;
+
+using log4net;
+using NUnit.Framework;
+using Apache.Qpid.Messaging;
+using Apache.Qpid.Client.Message;
+
+namespace Apache.Qpid.Client.Tests.Messages
+{
+   /// <summary>
+   /// Ensure a factory creates messages correctly
+   /// </summary>
+   [TestFixture]
+   public class MessageFactoryRegistryTests
+   {
+      const string TEXT_PLAIN = "text/plain";
+      const string TEXT_XML = "text/xml";
+      const string OCTET_STREAM = "application/octet-stream";
+
+      /// <summary>
+      /// Check default registry can create text/plain messages
+      /// </summary>
+      [Test]
+      public void CanCreateTextPlain()
+      {
+         MessageFactoryRegistry registry = 
+            MessageFactoryRegistry.NewDefaultRegistry();
+
+         IMessage message = registry.CreateMessage(TEXT_PLAIN);
+         Assert.IsNotNull(message);
+         Assert.AreEqual(TEXT_PLAIN, message.ContentType);
+         Assert.IsInstanceOfType(typeof(QpidTextMessage), message);
+      }
+      /// <summary>
+      /// Check default registry can create text/xml messages
+      /// </summary>
+      [Test]
+      public void CanCreateTextXml()
+      {
+         MessageFactoryRegistry registry =
+            MessageFactoryRegistry.NewDefaultRegistry();
+
+         IMessage message = registry.CreateMessage(TEXT_XML);
+         Assert.IsNotNull(message);
+         Assert.AreEqual(TEXT_XML, message.ContentType);
+         Assert.IsInstanceOfType(typeof(QpidTextMessage), message);
+      }
+      /// <summary>
+      /// Check default registry can create application/octet-stream messages
+      /// </summary>
+      [Test]
+      public void CanCreateBinary()
+      {
+         MessageFactoryRegistry registry =
+            MessageFactoryRegistry.NewDefaultRegistry();
+
+         IMessage message = registry.CreateMessage(OCTET_STREAM);
+         Assert.IsNotNull(message);
+         Assert.AreEqual(OCTET_STREAM, message.ContentType);
+         Assert.IsInstanceOfType(typeof(QpidBytesMessage), message);
+      }
+      /// <summary>
+      /// Check default registry can create messages for unknown types
+      /// </summary>
+      [Test]
+      public void CanCreateUnknownType()
+      {
+         MessageFactoryRegistry registry =
+            MessageFactoryRegistry.NewDefaultRegistry();
+
+         const string OTHER = "application/unknown";
+         IMessage message = registry.CreateMessage(OTHER);
+         Assert.IsNotNull(message);
+         Assert.AreEqual(OTHER, message.ContentType);
+         Assert.IsInstanceOfType(typeof(QpidBytesMessage), message);
+      }
+      /// <summary>
+      /// Check that text messages default to UTF-8 encoding
+      /// </summary>
+      [Test]
+      public void TextMessagesDefaultToUTF8Encoding()
+      {
+         MessageFactoryRegistry registry =
+            MessageFactoryRegistry.NewDefaultRegistry();
+
+         IMessage message = registry.CreateMessage(TEXT_PLAIN);
+         Assert.AreEqual("utf-8", message.ContentEncoding.ToLower());
+      }
+
+   }
+} // namespace Apache.Qpid.Client.Tests.Messages
+
+

Propchange: qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Messages/MessageFactoryRegistryTests.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Security/CallbackHandlerRegistryTests.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Security/CallbackHandlerRegistryTests.cs?rev=886998&r1=886997&r2=886998&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Security/CallbackHandlerRegistryTests.cs (original)
+++ qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Security/CallbackHandlerRegistryTests.cs Thu Dec  3 23:55:48 2009
@@ -1,66 +1,66 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-using System;
-using NUnit.Framework;
-using Apache.Qpid.Client.Security;
-
-
-namespace Apache.Qpid.Client.Tests.Security
-{
-   [TestFixture]
-   public class CallbackRegistryHandlerTests
-   {
-      [Test]
-      public void ParsesConfiguration()
-      {
-         CallbackHandlerRegistry registry = CallbackHandlerRegistry.Instance;
-         Assert.AreEqual(4, registry.Mechanisms.Length);
-         Assert.Contains("TEST", registry.Mechanisms);
-
-         Type handlerType = registry.GetCallbackHandler("TEST");
-         Assert.IsNotNull(handlerType);
-         Assert.AreEqual(typeof(TestCallbackHandler), handlerType);
-      }
-
-      [Test]
-      public void MechanimsInOrder()
-      {
-         CallbackHandlerRegistry registry = CallbackHandlerRegistry.Instance;
-         Assert.AreEqual(4, registry.Mechanisms.Length);
-         Assert.AreEqual("TEST", registry.Mechanisms[0]);
-         Assert.AreEqual("EXTERNAL", registry.Mechanisms[1]);
-         Assert.AreEqual("CRAM-MD5", registry.Mechanisms[2]);
-         Assert.AreEqual("PLAIN", registry.Mechanisms[3]);
-      }
-   } // class CallbackRegistryHandlerTests
-
-   public class TestCallbackHandler : IAMQCallbackHandler
-   {
-      public void Initialize(Qpid.Client.Protocol.AMQProtocolSession session)
-      {
-      }
-      public void Handle(Qpid.Sasl.ISaslCallback[] callbacks)
-      {
-      }
-
-   } // class TestCallbackHandler
-
-} // namespace Apache.Qpid.Client.Tests.Connection
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+using System;
+using NUnit.Framework;
+using Apache.Qpid.Client.Security;
+
+
+namespace Apache.Qpid.Client.Tests.Security
+{
+   [TestFixture]
+   public class CallbackRegistryHandlerTests
+   {
+      [Test]
+      public void ParsesConfiguration()
+      {
+         CallbackHandlerRegistry registry = CallbackHandlerRegistry.Instance;
+         Assert.AreEqual(4, registry.Mechanisms.Length);
+         Assert.Contains("TEST", registry.Mechanisms);
+
+         Type handlerType = registry.GetCallbackHandler("TEST");
+         Assert.IsNotNull(handlerType);
+         Assert.AreEqual(typeof(TestCallbackHandler), handlerType);
+      }
+
+      [Test]
+      public void MechanimsInOrder()
+      {
+         CallbackHandlerRegistry registry = CallbackHandlerRegistry.Instance;
+         Assert.AreEqual(4, registry.Mechanisms.Length);
+         Assert.AreEqual("TEST", registry.Mechanisms[0]);
+         Assert.AreEqual("EXTERNAL", registry.Mechanisms[1]);
+         Assert.AreEqual("CRAM-MD5", registry.Mechanisms[2]);
+         Assert.AreEqual("PLAIN", registry.Mechanisms[3]);
+      }
+   } // class CallbackRegistryHandlerTests
+
+   public class TestCallbackHandler : IAMQCallbackHandler
+   {
+      public void Initialize(Qpid.Client.Protocol.AMQProtocolSession session)
+      {
+      }
+      public void Handle(Qpid.Sasl.ISaslCallback[] callbacks)
+      {
+      }
+
+   } // class TestCallbackHandler
+
+} // namespace Apache.Qpid.Client.Tests.Connection

Propchange: qpid/trunk/qpid/dotnet/Qpid.Client.Tests/Security/CallbackHandlerRegistryTests.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: qpid/trunk/qpid/dotnet/Qpid.Client.Tests/interop/TopicListener.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/Qpid.Client.Tests/interop/TopicListener.cs?rev=886998&r1=886997&r2=886998&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/Qpid.Client.Tests/interop/TopicListener.cs (original)
+++ qpid/trunk/qpid/dotnet/Qpid.Client.Tests/interop/TopicListener.cs Thu Dec  3 23:55:48 2009
@@ -1,211 +1,211 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-using System;
-using log4net;
-using Apache.Qpid.Messaging;
-using Apache.Qpid.Client.Qms;
-
-namespace Apache.Qpid.Client.Tests.interop
-{
-    public class TopicListener
-    {
-        private static ILog log = LogManager.GetLogger(typeof(TopicListener));
-
-        /// <summary> The default AMQ connection URL to use for tests. </summary>
-        const string DEFAULT_URI = "amqp://guest:guest@default/test?brokerlist='tcp://localhost:5672'";
-
-        /// <summary> Holds the routing key for the topic to receive test messages on. </summary>
-        public static string CONTROL_ROUTING_KEY = "topic_control";
-
-        /// <summary> Holds the routing key for the queue to send reports to. </summary>
-        public static string RESPONSE_ROUTING_KEY = "response";
-
-        /// <summary> Holds the connection to listen on. </summary>
-        private IConnection connection;
-
-        /// <summary> Holds the channel for all test messages.</summary>
-        private IChannel channel;
-
-        /// <summary> Holds the producer to send report messages on. </summary>
-        private IMessagePublisher publisher;
-
-        /// <summary> Holds a flag to indicate that a timer has begun on the first message. Reset when report is sent. </summary> */
-        private bool init;
-    
-        /// <summary> Holds the count of messages received by this listener. </summary> */
-        private int count;
-
-        /// <summary> Creates a topic listener using the specified broker URL. </summary>
-        /// 
-        /// <param name="connectionUri">The broker URL to listen on.</param>
-        TopicListener(string connectionUri)
-        {
-            log.Debug("TopicListener(string connectionUri = " + connectionUri + "): called");
-
-            // Create a connection to the broker.
-            IConnectionInfo connectionInfo = QpidConnectionInfo.FromUrl(connectionUri);
-            connection = new AMQConnection(connectionInfo);
-
-            // Establish a session on the broker.
-            channel = connection.CreateChannel(false, AcknowledgeMode.AutoAcknowledge, 1);
-            
-            // Set up a queue to listen for test messages on.
-            string topicQueueName = channel.GenerateUniqueName();
-            channel.DeclareQueue(topicQueueName, false, true, true);
-
-            // Set this listener up to listen for incoming messages on the test topic queue.
-            channel.Bind(topicQueueName, ExchangeNameDefaults.TOPIC, CONTROL_ROUTING_KEY);
-            IMessageConsumer consumer = channel.CreateConsumerBuilder(topicQueueName)
-                .Create();
-            consumer.OnMessage += new MessageReceivedDelegate(OnMessage);
-
-            // Set up this listener with a producer to send the reports on.
-            publisher = channel.CreatePublisherBuilder()
-                .WithExchangeName(ExchangeNameDefaults.DIRECT)
-                .WithRoutingKey(RESPONSE_ROUTING_KEY)
-                .Create();
-
-            connection.Start();
-            Console.WriteLine("Waiting for messages...");
-        }
-
-        public static void Main(String[] argv)
-        {
-            // Create an instance of this listener with the command line parameters.
-            new TopicListener(DEFAULT_URI);
-        }
-
-        /// <summary> 
-        /// Handles all message received by this listener. Test messages are counted, report messages result in a report being sent and
-        /// shutdown messages result in this listener being terminated.
-        /// </summary>
-        /// 
-        /// <param name="message">The received message.</param>
-        public void OnMessage(IMessage message)
-        {
-            log.Debug("public void onMessage(Message message = " + message + "): called");
-
-            // Take the start time of the first message if this is the first message.
-            if (!init)
-            {
-                count = 0;
-                init = true;
-            }
-
-            // Check if the message is a control message telling this listener to shut down.
-            if (IsShutdown(message))
-            {
-                log.Debug("Got a shutdown message.");
-                Shutdown();
-            }
-            // Check if the message is a report request message asking this listener to respond with the message count.
-            else if (IsReport(message))
-            {
-                log.Debug("Got a report request message.");
-
-                // Send the message count report.
-                SendReport();
-
-                // Reset the initialization flag so that the next message is considered to be the first.
-                init = false;
-            }
-            // Otherwise it is an ordinary test message, so increment the message count.
-            else
-            {
-                count++;
-            }
-        }
-        
-        /// <summary> Checks a message to see if it is a shutdown control message. </summary>
-        /// 
-        /// <param name="m">The message to check.</param>
-        /// 
-        /// <returns><tt>true</tt> if it is a shutdown control message, <tt>false</tt> otherwise.</returns>
-        private bool IsShutdown(IMessage m) 
-        {
-            bool result = CheckTextField(m, "TYPE", "TERMINATION_REQUEST");
-
-            //log.Debug("isShutdown = " + result);
-
-            return result;
-        }
-
-        /// <summary> Checks a message to see if it is a report request control message. </summary>
-        /// 
-        /// <param name="m">The message to check.</param>
-        /// 
-        /// <returns><tt>true</tt> if it is a report request control message, <tt>false</tt> otherwise.</returns>
-        private bool IsReport(IMessage m) 
-        {
-            bool result = CheckTextField(m, "TYPE", "REPORT_REQUEST");
-
-            //log.Debug("isReport = " + result);
-
-            return result;
-        }
-
-        /// <summary> Checks whether or not a text field on a message has the specified value. </summary>
-        /// 
-        /// <param name="e">The message to check.</param>
-        /// <param name="e">The name of the field to check.</param>
-        /// <param name="e">The expected value of the field to compare with.</param>
-        /// 
-        /// <returns> <tt>true</tt>If the specified field has the specified value, <tt>fals</tt> otherwise. </returns>
-        private static bool CheckTextField(IMessage m, string fieldName, string value)
-        {
-            /*log.Debug("private static boolean checkTextField(Message m = " + m + ", String fieldName = " + fieldName
-                      + ", String value = " + value + "): called");*/
-
-            string comp = m.Headers.GetString(fieldName);
-
-            return (comp != null) && comp == value;
-        }
-
-        /// <summary> Stops the message consumer and closes the connection. </summary>
-        private void Shutdown()
-        {
-            connection.Stop();
-            channel.Dispose();
-            connection.Dispose();
-        }
-
-        /// <summary> Sends the report message to the response location. </summary>
-        private void SendReport()
-        {
-            string report = "Received " + count + ".";
-
-            IMessage reportMessage = channel.CreateTextMessage(report);
-
-            reportMessage.Headers.SetBoolean("BOOLEAN", false);
-            //reportMessage.Headers.SetByte("BYTE", 5);
-            reportMessage.Headers.SetDouble("DOUBLE", 3.141);
-            reportMessage.Headers.SetFloat("FLOAT", 1.0f);
-            reportMessage.Headers.SetInt("INT", 1);
-            reportMessage.Headers.SetLong("LONG", 1);
-            reportMessage.Headers.SetString("STRING", "hello");
-            reportMessage.Headers.SetShort("SHORT", 2);
-
-            publisher.Send(reportMessage);
-
-            Console.WriteLine("Sent report: " + report);
-        }
-    }
-}
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+using System;
+using log4net;
+using Apache.Qpid.Messaging;
+using Apache.Qpid.Client.Qms;
+
+namespace Apache.Qpid.Client.Tests.interop
+{
+    public class TopicListener
+    {
+        private static ILog log = LogManager.GetLogger(typeof(TopicListener));
+
+        /// <summary> The default AMQ connection URL to use for tests. </summary>
+        const string DEFAULT_URI = "amqp://guest:guest@default/test?brokerlist='tcp://localhost:5672'";
+
+        /// <summary> Holds the routing key for the topic to receive test messages on. </summary>
+        public static string CONTROL_ROUTING_KEY = "topic_control";
+
+        /// <summary> Holds the routing key for the queue to send reports to. </summary>
+        public static string RESPONSE_ROUTING_KEY = "response";
+
+        /// <summary> Holds the connection to listen on. </summary>
+        private IConnection connection;
+
+        /// <summary> Holds the channel for all test messages.</summary>
+        private IChannel channel;
+
+        /// <summary> Holds the producer to send report messages on. </summary>
+        private IMessagePublisher publisher;
+
+        /// <summary> Holds a flag to indicate that a timer has begun on the first message. Reset when report is sent. </summary> */
+        private bool init;
+    
+        /// <summary> Holds the count of messages received by this listener. </summary> */
+        private int count;
+
+        /// <summary> Creates a topic listener using the specified broker URL. </summary>
+        /// 
+        /// <param name="connectionUri">The broker URL to listen on.</param>
+        TopicListener(string connectionUri)
+        {
+            log.Debug("TopicListener(string connectionUri = " + connectionUri + "): called");
+
+            // Create a connection to the broker.
+            IConnectionInfo connectionInfo = QpidConnectionInfo.FromUrl(connectionUri);
+            connection = new AMQConnection(connectionInfo);
+
+            // Establish a session on the broker.
+            channel = connection.CreateChannel(false, AcknowledgeMode.AutoAcknowledge, 1);
+            
+            // Set up a queue to listen for test messages on.
+            string topicQueueName = channel.GenerateUniqueName();
+            channel.DeclareQueue(topicQueueName, false, true, true);
+
+            // Set this listener up to listen for incoming messages on the test topic queue.
+            channel.Bind(topicQueueName, ExchangeNameDefaults.TOPIC, CONTROL_ROUTING_KEY);
+            IMessageConsumer consumer = channel.CreateConsumerBuilder(topicQueueName)
+                .Create();
+            consumer.OnMessage += new MessageReceivedDelegate(OnMessage);
+
+            // Set up this listener with a producer to send the reports on.
+            publisher = channel.CreatePublisherBuilder()
+                .WithExchangeName(ExchangeNameDefaults.DIRECT)
+                .WithRoutingKey(RESPONSE_ROUTING_KEY)
+                .Create();
+
+            connection.Start();
+            Console.WriteLine("Waiting for messages...");
+        }
+
+        public static void Main(String[] argv)
+        {
+            // Create an instance of this listener with the command line parameters.
+            new TopicListener(DEFAULT_URI);
+        }
+
+        /// <summary> 
+        /// Handles all message received by this listener. Test messages are counted, report messages result in a report being sent and
+        /// shutdown messages result in this listener being terminated.
+        /// </summary>
+        /// 
+        /// <param name="message">The received message.</param>
+        public void OnMessage(IMessage message)
+        {
+            log.Debug("public void onMessage(Message message = " + message + "): called");
+
+            // Take the start time of the first message if this is the first message.
+            if (!init)
+            {
+                count = 0;
+                init = true;
+            }
+
+            // Check if the message is a control message telling this listener to shut down.
+            if (IsShutdown(message))
+            {
+                log.Debug("Got a shutdown message.");
+                Shutdown();
+            }
+            // Check if the message is a report request message asking this listener to respond with the message count.
+            else if (IsReport(message))
+            {
+                log.Debug("Got a report request message.");
+
+                // Send the message count report.
+                SendReport();
+
+                // Reset the initialization flag so that the next message is considered to be the first.
+                init = false;
+            }
+            // Otherwise it is an ordinary test message, so increment the message count.
+            else
+            {
+                count++;
+            }
+        }
+        
+        /// <summary> Checks a message to see if it is a shutdown control message. </summary>
+        /// 
+        /// <param name="m">The message to check.</param>
+        /// 
+        /// <returns><tt>true</tt> if it is a shutdown control message, <tt>false</tt> otherwise.</returns>
+        private bool IsShutdown(IMessage m) 
+        {
+            bool result = CheckTextField(m, "TYPE", "TERMINATION_REQUEST");
+
+            //log.Debug("isShutdown = " + result);
+
+            return result;
+        }
+
+        /// <summary> Checks a message to see if it is a report request control message. </summary>
+        /// 
+        /// <param name="m">The message to check.</param>
+        /// 
+        /// <returns><tt>true</tt> if it is a report request control message, <tt>false</tt> otherwise.</returns>
+        private bool IsReport(IMessage m) 
+        {
+            bool result = CheckTextField(m, "TYPE", "REPORT_REQUEST");
+
+            //log.Debug("isReport = " + result);
+
+            return result;
+        }
+
+        /// <summary> Checks whether or not a text field on a message has the specified value. </summary>
+        /// 
+        /// <param name="e">The message to check.</param>
+        /// <param name="e">The name of the field to check.</param>
+        /// <param name="e">The expected value of the field to compare with.</param>
+        /// 
+        /// <returns> <tt>true</tt>If the specified field has the specified value, <tt>fals</tt> otherwise. </returns>
+        private static bool CheckTextField(IMessage m, string fieldName, string value)
+        {
+            /*log.Debug("private static boolean checkTextField(Message m = " + m + ", String fieldName = " + fieldName
+                      + ", String value = " + value + "): called");*/
+
+            string comp = m.Headers.GetString(fieldName);
+
+            return (comp != null) && comp == value;
+        }
+
+        /// <summary> Stops the message consumer and closes the connection. </summary>
+        private void Shutdown()
+        {
+            connection.Stop();
+            channel.Dispose();
+            connection.Dispose();
+        }
+
+        /// <summary> Sends the report message to the response location. </summary>
+        private void SendReport()
+        {
+            string report = "Received " + count + ".";
+
+            IMessage reportMessage = channel.CreateTextMessage(report);
+
+            reportMessage.Headers.SetBoolean("BOOLEAN", false);
+            //reportMessage.Headers.SetByte("BYTE", 5);
+            reportMessage.Headers.SetDouble("DOUBLE", 3.141);
+            reportMessage.Headers.SetFloat("FLOAT", 1.0f);
+            reportMessage.Headers.SetInt("INT", 1);
+            reportMessage.Headers.SetLong("LONG", 1);
+            reportMessage.Headers.SetString("STRING", "hello");
+            reportMessage.Headers.SetShort("SHORT", 2);
+
+            publisher.Send(reportMessage);
+
+            Console.WriteLine("Sent report: " + report);
+        }
+    }
+}

Propchange: qpid/trunk/qpid/dotnet/Qpid.Client.Tests/interop/TopicListener.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: qpid/trunk/qpid/dotnet/Qpid.Client.Tests/interop/TopicPublisher.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/Qpid.Client.Tests/interop/TopicPublisher.cs?rev=886998&r1=886997&r2=886998&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/Qpid.Client.Tests/interop/TopicPublisher.cs (original)
+++ qpid/trunk/qpid/dotnet/Qpid.Client.Tests/interop/TopicPublisher.cs Thu Dec  3 23:55:48 2009
@@ -1,208 +1,208 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-using System;
-using System.Threading;
-using log4net;
-using Apache.Qpid.Messaging;
-using Apache.Qpid.Client.Qms;
-
-namespace Apache.Qpid.Client.Tests.interop
-{
-    public class TopicPublisher
-    {
-        private static ILog log = LogManager.GetLogger(typeof(TopicPublisher));
-
-        /// <summary> The default AMQ connection URL to use for tests. </summary>
-        const string DEFAULT_URI = "amqp://guest:guest@default/test?brokerlist='tcp://localhost:5672'";
-
-        /// <summary> Holds the default test timeout for broker communications before tests give up. </summary>
-        const int TIMEOUT = 10000;
-
-        /// <summary> Holds the routing key for the topic to receive test messages on. </summary>
-        const string CONTROL_ROUTING_KEY = "topic_control";
-
-        /// <summary> Holds the routing key for the queue to send reports to. </summary>
-        const string RESPONSE_ROUTING_KEY = "response";
-
-        /// <summary> Holds the number of messages to send in each test run. </summary>
-        private int numMessages;
-
-        /// <summary> Holds the number of subscribers listening to the messsages. </summary>
-        private int numSubscribers;
-
-        /// <summary> A monitor used to wait for all reports to arrive back from consumers on. </summary>
-        private AutoResetEvent allReportsReceivedEvt = new AutoResetEvent(false);
-
-        /// <summary> Holds the connection to listen on. </summary>
-        private IConnection connection;
-
-        /// <summary> Holds the channel for all test messages.</summary>
-        private IChannel channel;
-
-        /// <summary> Holds the producer to send test messages on. </summary>
-        private IMessagePublisher publisher;
-
-        /// <summary>
-        /// Creates a topic publisher that will send the specifed number of messages and expect the specifed number of report back from test
-        /// subscribers.
-        /// </summary>
-        /// 
-        /// <param name="connectionUri">The broker URL.</param>
-        /// <param name="numMessages">The number of messages to send in each test.</param>
-        /// <param name="numSubscribers">The number of subscribes that are expected to reply with a report.</param>
-        TopicPublisher(string connectionUri, int numMessages, int numSubscribers)
-        {
-            log.Debug("TopicPublisher(string connectionUri = " + connectionUri + ", int numMessages = "+ numMessages + 
-                      ", int numSubscribers = " + numSubscribers + "): called");
-
-            // Create a connection to the broker.
-            IConnectionInfo connectionInfo = QpidConnectionInfo.FromUrl(connectionUri);
-            connection = new AMQConnection(connectionInfo);
-
-            // Establish a session on the broker.
-            channel = connection.CreateChannel(false, AcknowledgeMode.AutoAcknowledge, 1);
-
-            // Set up a queue to listen for reports on.
-            string responseQueueName = channel.GenerateUniqueName();
-            channel.DeclareQueue(responseQueueName, false, true, true);
-            
-            // Set this listener up to listen for reports on the response queue.
-            channel.Bind(responseQueueName, ExchangeNameDefaults.DIRECT, RESPONSE_ROUTING_KEY);
-            //channel.Bind(responseQueueName, "<<default>>", RESPONSE_ROUTING_KEY);
-            IMessageConsumer consumer = channel.CreateConsumerBuilder(responseQueueName)               
-                .Create();
-            consumer.OnMessage += new MessageReceivedDelegate(OnMessage);
-
-            // Set up this listener with a producer to send the test messages and report requests on.
-            publisher = channel.CreatePublisherBuilder()
-                .WithExchangeName(ExchangeNameDefaults.TOPIC)
-                .WithRoutingKey(CONTROL_ROUTING_KEY)
-                .Create();
-
-            // Keep the test parameters.
-            this.numMessages = numMessages;
-            this.numSubscribers = numSubscribers;
-
-            connection.Start();
-            Console.WriteLine("Sending messages and waiting for reports...");
-        }
-
-        /// <summary>
-        /// Start a test subscriber. The broker URL must be specified as the first command line argument.
-        /// </summary>
-        /// 
-        /// <param name="argv">The command line arguments, broker URL first.</param>
-        public static void Main(String[] argv)
-        {
-            // Create an instance of this publisher with the command line parameters.
-            TopicPublisher publisher = new TopicPublisher(DEFAULT_URI, 1, 1);
-
-            // Publish the test messages.
-            publisher.DoTest();
-        }
-
-        /// <summary>
-        /// Sends the test messages and waits for all subscribers to reply with a report.
-        /// </summary>
-        public void DoTest()
-        {
-            log.Debug("public void DoTest(): called");
-
-            // Create a test message to send.
-            IMessage testMessage = channel.CreateTextMessage("test");
-
-            // Send the desired number of test messages.
-            for (int i = 0; i < numMessages; i++)
-            {
-                publisher.Send(testMessage);
-            }
-
-            log.Debug("Sent " + numMessages + " test messages.");
-
-            // Send the report request.
-            IMessage reportRequestMessage = channel.CreateTextMessage("Report request message.");
-            reportRequestMessage.Headers["TYPE"] = "REPORT_REQUEST";
-            
-            reportRequestMessage.Headers.SetBoolean("BOOLEAN", false);
-            //reportRequestMessage.Headers.SetByte("BYTE", 5);
-            reportRequestMessage.Headers.SetDouble("DOUBLE", 3.141);
-            reportRequestMessage.Headers.SetFloat("FLOAT", 1.0f);
-            reportRequestMessage.Headers.SetInt("INT", 1);
-            reportRequestMessage.Headers.SetLong("LONG", 1);
-            reportRequestMessage.Headers.SetString("STRING", "hello");
-            reportRequestMessage.Headers.SetShort("SHORT", 2);
-
-            publisher.Send(reportRequestMessage);
-
-            log.Debug("Sent the report request message, waiting for all replies...");
-
-            // Wait until all the reports come in.
-            allReportsReceivedEvt.WaitOne(TIMEOUT, true);
-
-            // Check if all reports were really received or if the timeout occurred.
-            if (numSubscribers == 0)
-            {
-                log.Debug("Got all reports.");
-            }
-            else
-            {
-                log.Debug("Waiting for reports timed out, still waiting for " + numSubscribers + ".");
-            }
-
-            // Send the termination request.
-            IMessage terminationRequestMessage = channel.CreateTextMessage("Termination request message.");
-            terminationRequestMessage.Headers["TYPE"] =  "TERMINATION_REQUEST";
-            publisher.Send(terminationRequestMessage);
-
-            log.Debug("Sent the termination request message.");
-
-            // Close all message producers and consumers and the connection to the broker.
-            Shutdown();
-        }
-
-        /// <summary>
-        /// Handles all report messages from subscribers. This decrements the count of subscribers that are still to reply, until this becomes
-        /// zero, at which time waiting threads are notified of this event.
-        /// </summary>
-        /// 
-        /// <param name="message">The received report message.</param>
-        public void OnMessage(IMessage message)
-        {
-            log.Debug("public void OnMessage(IMessage message = " + message + "): called");
-
-            // Decrement the count of expected messages and release the wait monitor when this becomes zero.
-            if (--numSubscribers == 0)
-            {
-                log.Debug("Got reports from all subscribers.");
-                allReportsReceivedEvt.Set();
-            }
-        }
-
-        /// <summary> Stops the message consumers and closes the connection. </summary>
-        private void Shutdown()
-        {
-            connection.Stop();
-            publisher.Dispose();
-            channel.Dispose();
-            connection.Dispose();
-        }
-    }
-}
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+using System;
+using System.Threading;
+using log4net;
+using Apache.Qpid.Messaging;
+using Apache.Qpid.Client.Qms;
+
+namespace Apache.Qpid.Client.Tests.interop
+{
+    public class TopicPublisher
+    {
+        private static ILog log = LogManager.GetLogger(typeof(TopicPublisher));
+
+        /// <summary> The default AMQ connection URL to use for tests. </summary>
+        const string DEFAULT_URI = "amqp://guest:guest@default/test?brokerlist='tcp://localhost:5672'";
+
+        /// <summary> Holds the default test timeout for broker communications before tests give up. </summary>
+        const int TIMEOUT = 10000;
+
+        /// <summary> Holds the routing key for the topic to receive test messages on. </summary>
+        const string CONTROL_ROUTING_KEY = "topic_control";
+
+        /// <summary> Holds the routing key for the queue to send reports to. </summary>
+        const string RESPONSE_ROUTING_KEY = "response";
+
+        /// <summary> Holds the number of messages to send in each test run. </summary>
+        private int numMessages;
+
+        /// <summary> Holds the number of subscribers listening to the messsages. </summary>
+        private int numSubscribers;
+
+        /// <summary> A monitor used to wait for all reports to arrive back from consumers on. </summary>
+        private AutoResetEvent allReportsReceivedEvt = new AutoResetEvent(false);
+
+        /// <summary> Holds the connection to listen on. </summary>
+        private IConnection connection;
+
+        /// <summary> Holds the channel for all test messages.</summary>
+        private IChannel channel;
+
+        /// <summary> Holds the producer to send test messages on. </summary>
+        private IMessagePublisher publisher;
+
+        /// <summary>
+        /// Creates a topic publisher that will send the specifed number of messages and expect the specifed number of report back from test
+        /// subscribers.
+        /// </summary>
+        /// 
+        /// <param name="connectionUri">The broker URL.</param>
+        /// <param name="numMessages">The number of messages to send in each test.</param>
+        /// <param name="numSubscribers">The number of subscribes that are expected to reply with a report.</param>
+        TopicPublisher(string connectionUri, int numMessages, int numSubscribers)
+        {
+            log.Debug("TopicPublisher(string connectionUri = " + connectionUri + ", int numMessages = "+ numMessages + 
+                      ", int numSubscribers = " + numSubscribers + "): called");
+
+            // Create a connection to the broker.
+            IConnectionInfo connectionInfo = QpidConnectionInfo.FromUrl(connectionUri);
+            connection = new AMQConnection(connectionInfo);
+
+            // Establish a session on the broker.
+            channel = connection.CreateChannel(false, AcknowledgeMode.AutoAcknowledge, 1);
+
+            // Set up a queue to listen for reports on.
+            string responseQueueName = channel.GenerateUniqueName();
+            channel.DeclareQueue(responseQueueName, false, true, true);
+            
+            // Set this listener up to listen for reports on the response queue.
+            channel.Bind(responseQueueName, ExchangeNameDefaults.DIRECT, RESPONSE_ROUTING_KEY);
+            //channel.Bind(responseQueueName, "<<default>>", RESPONSE_ROUTING_KEY);
+            IMessageConsumer consumer = channel.CreateConsumerBuilder(responseQueueName)               
+                .Create();
+            consumer.OnMessage += new MessageReceivedDelegate(OnMessage);
+
+            // Set up this listener with a producer to send the test messages and report requests on.
+            publisher = channel.CreatePublisherBuilder()
+                .WithExchangeName(ExchangeNameDefaults.TOPIC)
+                .WithRoutingKey(CONTROL_ROUTING_KEY)
+                .Create();
+
+            // Keep the test parameters.
+            this.numMessages = numMessages;
+            this.numSubscribers = numSubscribers;
+
+            connection.Start();
+            Console.WriteLine("Sending messages and waiting for reports...");
+        }
+
+        /// <summary>
+        /// Start a test subscriber. The broker URL must be specified as the first command line argument.
+        /// </summary>
+        /// 
+        /// <param name="argv">The command line arguments, broker URL first.</param>
+        public static void Main(String[] argv)
+        {
+            // Create an instance of this publisher with the command line parameters.
+            TopicPublisher publisher = new TopicPublisher(DEFAULT_URI, 1, 1);
+
+            // Publish the test messages.
+            publisher.DoTest();
+        }
+
+        /// <summary>
+        /// Sends the test messages and waits for all subscribers to reply with a report.
+        /// </summary>
+        public void DoTest()
+        {
+            log.Debug("public void DoTest(): called");
+
+            // Create a test message to send.
+            IMessage testMessage = channel.CreateTextMessage("test");
+
+            // Send the desired number of test messages.
+            for (int i = 0; i < numMessages; i++)
+            {
+                publisher.Send(testMessage);
+            }
+
+            log.Debug("Sent " + numMessages + " test messages.");
+
+            // Send the report request.
+            IMessage reportRequestMessage = channel.CreateTextMessage("Report request message.");
+            reportRequestMessage.Headers["TYPE"] = "REPORT_REQUEST";
+            
+            reportRequestMessage.Headers.SetBoolean("BOOLEAN", false);
+            //reportRequestMessage.Headers.SetByte("BYTE", 5);
+            reportRequestMessage.Headers.SetDouble("DOUBLE", 3.141);
+            reportRequestMessage.Headers.SetFloat("FLOAT", 1.0f);
+            reportRequestMessage.Headers.SetInt("INT", 1);
+            reportRequestMessage.Headers.SetLong("LONG", 1);
+            reportRequestMessage.Headers.SetString("STRING", "hello");
+            reportRequestMessage.Headers.SetShort("SHORT", 2);
+
+            publisher.Send(reportRequestMessage);
+
+            log.Debug("Sent the report request message, waiting for all replies...");
+
+            // Wait until all the reports come in.
+            allReportsReceivedEvt.WaitOne(TIMEOUT, true);
+
+            // Check if all reports were really received or if the timeout occurred.
+            if (numSubscribers == 0)
+            {
+                log.Debug("Got all reports.");
+            }
+            else
+            {
+                log.Debug("Waiting for reports timed out, still waiting for " + numSubscribers + ".");
+            }
+
+            // Send the termination request.
+            IMessage terminationRequestMessage = channel.CreateTextMessage("Termination request message.");
+            terminationRequestMessage.Headers["TYPE"] =  "TERMINATION_REQUEST";
+            publisher.Send(terminationRequestMessage);
+
+            log.Debug("Sent the termination request message.");
+
+            // Close all message producers and consumers and the connection to the broker.
+            Shutdown();
+        }
+
+        /// <summary>
+        /// Handles all report messages from subscribers. This decrements the count of subscribers that are still to reply, until this becomes
+        /// zero, at which time waiting threads are notified of this event.
+        /// </summary>
+        /// 
+        /// <param name="message">The received report message.</param>
+        public void OnMessage(IMessage message)
+        {
+            log.Debug("public void OnMessage(IMessage message = " + message + "): called");
+
+            // Decrement the count of expected messages and release the wait monitor when this becomes zero.
+            if (--numSubscribers == 0)
+            {
+                log.Debug("Got reports from all subscribers.");
+                allReportsReceivedEvt.Set();
+            }
+        }
+
+        /// <summary> Stops the message consumers and closes the connection. </summary>
+        private void Shutdown()
+        {
+            connection.Stop();
+            publisher.Dispose();
+            channel.Dispose();
+            connection.Dispose();
+        }
+    }
+}

Propchange: qpid/trunk/qpid/dotnet/Qpid.Client.Tests/interop/TopicPublisher.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQAuthenticationException.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQAuthenticationException.cs?rev=886998&r1=886997&r2=886998&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQAuthenticationException.cs (original)
+++ qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQAuthenticationException.cs Thu Dec  3 23:55:48 2009
@@ -1,39 +1,39 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-using System;
-using System.Runtime.Serialization;
-
-namespace Apache.Qpid.Client
-{
-    [Serializable]
-    public class AMQAuthenticationException : AMQException
-    {
-        public AMQAuthenticationException(int error, String message) 
-           : base(error, message)
-        {
-        }
-
-        protected AMQAuthenticationException(SerializationInfo info, StreamingContext ctxt)
-           : base(info, ctxt)
-        {
-        }
-    }
-}
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+using System;
+using System.Runtime.Serialization;
+
+namespace Apache.Qpid.Client
+{
+    [Serializable]
+    public class AMQAuthenticationException : AMQException
+    {
+        public AMQAuthenticationException(int error, String message) 
+           : base(error, message)
+        {
+        }
+
+        protected AMQAuthenticationException(SerializationInfo info, StreamingContext ctxt)
+           : base(info, ctxt)
+        {
+        }
+    }
+}

Propchange: qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQAuthenticationException.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQNoConsumersException.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQNoConsumersException.cs?rev=886998&r1=886997&r2=886998&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQNoConsumersException.cs (original)
+++ qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQNoConsumersException.cs Thu Dec  3 23:55:48 2009
@@ -1,45 +1,45 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-using System;
-using System.Runtime.Serialization;
-using Apache.Qpid.Common;
-using Apache.Qpid.Protocol;
-
-namespace Apache.Qpid.Client
-{
-   [Serializable]
-   public class AMQNoConsumersException : AMQUndeliveredException
-   {
-      public AMQNoConsumersException(string message)
-         : this(message, null)
-      {
-      }
-
-      public AMQNoConsumersException(string message, object bounced)
-         : base(AMQConstant.NO_CONSUMERS.Code, message, bounced)
-      {
-      }
-      protected AMQNoConsumersException(SerializationInfo info, StreamingContext ctxt)
-         : base(info, ctxt)
-      {
-      }
-   }
-}
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+using System;
+using System.Runtime.Serialization;
+using Apache.Qpid.Common;
+using Apache.Qpid.Protocol;
+
+namespace Apache.Qpid.Client
+{
+   [Serializable]
+   public class AMQNoConsumersException : AMQUndeliveredException
+   {
+      public AMQNoConsumersException(string message)
+         : this(message, null)
+      {
+      }
+
+      public AMQNoConsumersException(string message, object bounced)
+         : base(AMQConstant.NO_CONSUMERS.Code, message, bounced)
+      {
+      }
+      protected AMQNoConsumersException(SerializationInfo info, StreamingContext ctxt)
+         : base(info, ctxt)
+      {
+      }
+   }
+}

Propchange: qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQNoConsumersException.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQNoRouteException.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQNoRouteException.cs?rev=886998&r1=886997&r2=886998&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQNoRouteException.cs (original)
+++ qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQNoRouteException.cs Thu Dec  3 23:55:48 2009
@@ -1,46 +1,46 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-using System;
-using System.Runtime.Serialization;
-using Apache.Qpid.Common;
-using Apache.Qpid.Protocol;
-
-namespace Apache.Qpid.Client
-{
-   [Serializable]
-   public class AMQNoRouteException : AMQUndeliveredException
-   {
-      public AMQNoRouteException(string message)
-         : this(message, null)
-      {
-      }
-
-      public AMQNoRouteException(string message, object bounced)
-         : base(AMQConstant.NO_ROUTE.Code, message, bounced)
-      {
-      }
-
-      protected AMQNoRouteException(SerializationInfo info, StreamingContext ctxt)
-         : base(info, ctxt)
-      {
-      }
-   }
-}
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+using System;
+using System.Runtime.Serialization;
+using Apache.Qpid.Common;
+using Apache.Qpid.Protocol;
+
+namespace Apache.Qpid.Client
+{
+   [Serializable]
+   public class AMQNoRouteException : AMQUndeliveredException
+   {
+      public AMQNoRouteException(string message)
+         : this(message, null)
+      {
+      }
+
+      public AMQNoRouteException(string message, object bounced)
+         : base(AMQConstant.NO_ROUTE.Code, message, bounced)
+      {
+      }
+
+      protected AMQNoRouteException(SerializationInfo info, StreamingContext ctxt)
+         : base(info, ctxt)
+      {
+      }
+   }
+}

Propchange: qpid/trunk/qpid/dotnet/Qpid.Client/Client/AMQNoRouteException.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: qpid/trunk/qpid/dotnet/Qpid.Client/Client/Configuration/AuthenticationConfigurationSectionHandler.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/Qpid.Client/Client/Configuration/AuthenticationConfigurationSectionHandler.cs?rev=886998&r1=886997&r2=886998&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/Qpid.Client/Client/Configuration/AuthenticationConfigurationSectionHandler.cs (original)
+++ qpid/trunk/qpid/dotnet/Qpid.Client/Client/Configuration/AuthenticationConfigurationSectionHandler.cs Thu Dec  3 23:55:48 2009
@@ -1,84 +1,84 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-using System;
-using System.Collections;
-using System.Collections.Specialized;
-using System.Configuration;
-using System.Text;
-
-using Apache.Qpid.Client.Security;
-using Apache.Qpid.Sasl.Mechanisms;
-
-namespace Apache.Qpid.Client.Configuration
-{
-   public class AuthenticationConfigurationSectionHandler 
-      : IConfigurationSectionHandler
-   {
-
-      public object Create(object parent, object configContext, System.Xml.XmlNode section)
-      {
-         NameValueSectionHandler handler = new NameValueSectionHandler();
-         OrderedHashTable schemes = new OrderedHashTable();
-
-         NameValueCollection options = (NameValueCollection)
-            handler.Create(parent, configContext, section);
-
-         if ( options != null )
-         {
-            foreach ( string key in options.Keys )
-            {
-               Type type = Type.GetType(options[key]);
-               if ( type == null )
-                  throw new ConfigurationException(string.Format("Type '{0}' not found", key));
-               if ( !typeof(IAMQCallbackHandler).IsAssignableFrom(type) )
-                  throw new ConfigurationException(string.Format("Type '{0}' does not implement IAMQCallbackHandler", key));
-
-               schemes.Add(key, type);
-            }
-         }
-
-         return schemes;
-      }
-
-   } // class AuthenticationConfigurationSectionHandler
-
-   public class OrderedHashTable : Hashtable
-   {
-      private ArrayList _keys = new ArrayList();
-
-      public IList OrderedKeys
-      {
-         get { return _keys; }
-      }
-
-      public override void Add(object key, object value)
-      {
-         base.Add(key, value);
-         _keys.Add(key);
-      }
-      public override void Remove(object key)
-      {
-         base.Remove(key);
-         _keys.Remove(key);
-      }
-   }
-} // namespace Apache.Qpid.Client.Configuration
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+using System;
+using System.Collections;
+using System.Collections.Specialized;
+using System.Configuration;
+using System.Text;
+
+using Apache.Qpid.Client.Security;
+using Apache.Qpid.Sasl.Mechanisms;
+
+namespace Apache.Qpid.Client.Configuration
+{
+   public class AuthenticationConfigurationSectionHandler 
+      : IConfigurationSectionHandler
+   {
+
+      public object Create(object parent, object configContext, System.Xml.XmlNode section)
+      {
+         NameValueSectionHandler handler = new NameValueSectionHandler();
+         OrderedHashTable schemes = new OrderedHashTable();
+
+         NameValueCollection options = (NameValueCollection)
+            handler.Create(parent, configContext, section);
+
+         if ( options != null )
+         {
+            foreach ( string key in options.Keys )
+            {
+               Type type = Type.GetType(options[key]);
+               if ( type == null )
+                  throw new ConfigurationException(string.Format("Type '{0}' not found", key));
+               if ( !typeof(IAMQCallbackHandler).IsAssignableFrom(type) )
+                  throw new ConfigurationException(string.Format("Type '{0}' does not implement IAMQCallbackHandler", key));
+
+               schemes.Add(key, type);
+            }
+         }
+
+         return schemes;
+      }
+
+   } // class AuthenticationConfigurationSectionHandler
+
+   public class OrderedHashTable : Hashtable
+   {
+      private ArrayList _keys = new ArrayList();
+
+      public IList OrderedKeys
+      {
+         get { return _keys; }
+      }
+
+      public override void Add(object key, object value)
+      {
+         base.Add(key, value);
+         _keys.Add(key);
+      }
+      public override void Remove(object key)
+      {
+         base.Remove(key);
+         _keys.Remove(key);
+      }
+   }
+} // namespace Apache.Qpid.Client.Configuration

Propchange: qpid/trunk/qpid/dotnet/Qpid.Client/Client/Configuration/AuthenticationConfigurationSectionHandler.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: qpid/trunk/qpid/dotnet/Qpid.Client/Client/Handler/QueueDeleteOkMethodHandler.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/Qpid.Client/Client/Handler/QueueDeleteOkMethodHandler.cs?rev=886998&r1=886997&r2=886998&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/Qpid.Client/Client/Handler/QueueDeleteOkMethodHandler.cs (original)
+++ qpid/trunk/qpid/dotnet/Qpid.Client/Client/Handler/QueueDeleteOkMethodHandler.cs Thu Dec  3 23:55:48 2009
@@ -1,44 +1,44 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-using log4net;
-using Apache.Qpid.Client.Message;
-using Apache.Qpid.Client.Protocol;
-using Apache.Qpid.Client.State;
-using Apache.Qpid.Framing;
-
-namespace Apache.Qpid.Client.Handler
-{
-    public class QueueDeleteOkMethodHandler : IStateAwareMethodListener
-    {
-
-        private static readonly ILog _logger = LogManager.GetLogger(typeof(QueueDeleteOkMethodHandler));
-
-        public void MethodReceived(AMQStateManager stateManager, AMQMethodEvent evt)
-        {
-            QueueDeleteOkBody body = (QueueDeleteOkBody)evt.Method;
-            if (body != null)
-            {
-                _logger.InfoFormat("Received Queue.Delete-Ok message, message count {0}", body.MessageCount);
-            }
-        }
-
-    }
-}
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+using log4net;
+using Apache.Qpid.Client.Message;
+using Apache.Qpid.Client.Protocol;
+using Apache.Qpid.Client.State;
+using Apache.Qpid.Framing;
+
+namespace Apache.Qpid.Client.Handler
+{
+    public class QueueDeleteOkMethodHandler : IStateAwareMethodListener
+    {
+
+        private static readonly ILog _logger = LogManager.GetLogger(typeof(QueueDeleteOkMethodHandler));
+
+        public void MethodReceived(AMQStateManager stateManager, AMQMethodEvent evt)
+        {
+            QueueDeleteOkBody body = (QueueDeleteOkBody)evt.Method;
+            if (body != null)
+            {
+                _logger.InfoFormat("Received Queue.Delete-Ok message, message count {0}", body.MessageCount);
+            }
+        }
+
+    }
+}

Propchange: qpid/trunk/qpid/dotnet/Qpid.Client/Client/Handler/QueueDeleteOkMethodHandler.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: qpid/trunk/qpid/dotnet/Qpid.Client/Client/Handler/QueuePurgeOkMethodHandler.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/Qpid.Client/Client/Handler/QueuePurgeOkMethodHandler.cs?rev=886998&r1=886997&r2=886998&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/Qpid.Client/Client/Handler/QueuePurgeOkMethodHandler.cs (original)
+++ qpid/trunk/qpid/dotnet/Qpid.Client/Client/Handler/QueuePurgeOkMethodHandler.cs Thu Dec  3 23:55:48 2009
@@ -1,44 +1,44 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-using log4net;
-using Apache.Qpid.Client.Message;
-using Apache.Qpid.Client.Protocol;
-using Apache.Qpid.Client.State;
-using Apache.Qpid.Framing;
-
-namespace Apache.Qpid.Client.Handler
-{
-    public class QueuePurgeOkMethodHandler : IStateAwareMethodListener
-    {
-
-        private static readonly ILog _logger = LogManager.GetLogger(typeof(QueuePurgeOkMethodHandler));
-
-        public void MethodReceived(AMQStateManager stateManager, AMQMethodEvent evt)
-        {
-            QueuePurgeOkBody body = (QueuePurgeOkBody)evt.Method;
-            if (body != null)
-            {
-                _logger.InfoFormat("Received Queue.Purge-Ok message, message count {0}", body.MessageCount);
-            }
-        }
-
-    }
-}
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+using log4net;
+using Apache.Qpid.Client.Message;
+using Apache.Qpid.Client.Protocol;
+using Apache.Qpid.Client.State;
+using Apache.Qpid.Framing;
+
+namespace Apache.Qpid.Client.Handler
+{
+    public class QueuePurgeOkMethodHandler : IStateAwareMethodListener
+    {
+
+        private static readonly ILog _logger = LogManager.GetLogger(typeof(QueuePurgeOkMethodHandler));
+
+        public void MethodReceived(AMQStateManager stateManager, AMQMethodEvent evt)
+        {
+            QueuePurgeOkBody body = (QueuePurgeOkBody)evt.Method;
+            if (body != null)
+            {
+                _logger.InfoFormat("Received Queue.Purge-Ok message, message count {0}", body.MessageCount);
+            }
+        }
+
+    }
+}

Propchange: qpid/trunk/qpid/dotnet/Qpid.Client/Client/Handler/QueuePurgeOkMethodHandler.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: qpid/trunk/qpid/dotnet/Qpid.Client/Client/Protocol/DefaultTimeouts.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/Qpid.Client/Client/Protocol/DefaultTimeouts.cs?rev=886998&r1=886997&r2=886998&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/Qpid.Client/Client/Protocol/DefaultTimeouts.cs (original)
+++ qpid/trunk/qpid/dotnet/Qpid.Client/Client/Protocol/DefaultTimeouts.cs Thu Dec  3 23:55:48 2009
@@ -1,47 +1,47 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-using System;
-using System.Text;
-
-namespace Apache.Qpid.Client.Protocol
-{
-   /// <summary>
-   /// Default timeout values for the protocol
-   /// </summary>
-   sealed class DefaultTimeouts
-   {
-      /// <summary>
-      /// Maximum number of milliseconds to wait for a state change
-      /// in the protocol's state machine
-      /// </summary>
-      public const int MaxWaitForState = 30* 1000;
-      /// <summary>
-      /// Maximum number of milliseconds to wait for a reply
-      /// frame when doing synchronous writer to the broker
-      /// </summary>
-      public const int MaxWaitForSyncWriter = 30 * 1000;
-
-      private DefaultTimeouts()
-      {
-      }
-   }
-}
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+using System;
+using System.Text;
+
+namespace Apache.Qpid.Client.Protocol
+{
+   /// <summary>
+   /// Default timeout values for the protocol
+   /// </summary>
+   sealed class DefaultTimeouts
+   {
+      /// <summary>
+      /// Maximum number of milliseconds to wait for a state change
+      /// in the protocol's state machine
+      /// </summary>
+      public const int MaxWaitForState = 30* 1000;
+      /// <summary>
+      /// Maximum number of milliseconds to wait for a reply
+      /// frame when doing synchronous writer to the broker
+      /// </summary>
+      public const int MaxWaitForSyncWriter = 30 * 1000;
+
+      private DefaultTimeouts()
+      {
+      }
+   }
+}

Propchange: qpid/trunk/qpid/dotnet/Qpid.Client/Client/Protocol/DefaultTimeouts.cs
------------------------------------------------------------------------------
    svn:eol-style = native



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org