From 4ccdc650d654826b4e04a4bed90291eb96d133e1 Mon Sep 17 00:00:00 2001
From: Rupert Smith <rupertlssmith@apache.org>
Date: Thu, 24 Jan 2008 16:44:37 +0000
Subject: Dropped test, as it does not do anything that other tests already do,
 particularly the ProducerMultiConsumer test.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@614921 13f79535-47bb-0310-9956-ffa450edef68
---
 .../testcases/SyncConsumerTest.cs                  | 139 ---------------------
 1 file changed, 139 deletions(-)
 delete mode 100644 dotnet/Qpid.Integration.Tests/testcases/SyncConsumerTest.cs

diff --git a/dotnet/Qpid.Integration.Tests/testcases/SyncConsumerTest.cs b/dotnet/Qpid.Integration.Tests/testcases/SyncConsumerTest.cs
deleted file mode 100644
index b1f100447e..0000000000
--- a/dotnet/Qpid.Integration.Tests/testcases/SyncConsumerTest.cs
+++ /dev/null
@@ -1,139 +0,0 @@
-/*
- *
- * 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;
-using System.Threading;
-using log4net;
-using NUnit.Framework;
-using Apache.Qpid.Messaging;
-using Apache.Qpid.Client.Qms;
-using Apache.Qpid.Client;
-
-namespace Apache.Qpid.Integration.Tests.testcases
-{
-    [TestFixture, Category("Integration")]
-    public class SyncConsumerTest : BaseMessagingTestFixture
-    {
-        private static readonly ILog _logger = LogManager.GetLogger(typeof(SyncConsumerTest));
-        
-        private string _commandQueueName = "ServiceQ1";
-        private const int MESSAGE_COUNT = 1000;
-
-        private IMessageConsumer _consumer;
-        private IMessagePublisher _publisher;
-
-        /// <summary> Holds the test connection. </summary>
-        protected IConnection _connection;
-
-        /// <summary> Holds the test channel. </summary>
-        protected IChannel _channel;
-        
-        [SetUp]
-        public override void Init()
-        {
-            base.Init();
-
-            _connection = new AMQConnection(connectionInfo);
-            _channel = _connection.CreateChannel(false, AcknowledgeMode.AutoAcknowledge, 500, 300);
-
-            _publisher = _channel.CreatePublisherBuilder()
-                .WithRoutingKey(_commandQueueName)
-                .WithExchangeName(ExchangeNameDefaults.TOPIC)
-                .Create();
-            
-            _publisher.DisableMessageTimestamp = true;
-            _publisher.DeliveryMode = DeliveryMode.NonPersistent;
-            
-            string queueName = _channel.GenerateUniqueName();
-            _channel.DeclareQueue(queueName, false, true, true);
-            
-            _channel.Bind(queueName, ExchangeNameDefaults.TOPIC, _commandQueueName);
-            
-            _consumer = _channel.CreateConsumerBuilder(queueName)
-                .WithPrefetchLow(100).Create();
-            _connection.Start();
-        }
-
-        /// <summary>
-        /// Deregisters the on message delegate before closing the connection.
-        /// </summary>
-        [TearDown]
-        public override void Shutdown()
-        {
-            _logger.Info("public void Shutdown(): called");
-
-            //_consumer.OnMessage -= _msgRecDelegate;
-            //_connection.ExceptionListener -= _exceptionDelegate;
-
-            _connection.Stop();
-            _connection.Close();
-            _connection.Dispose();
-
-            base.Shutdown();
-        }
-
-        [Test]
-        public void ReceiveWithInfiniteWait()
-        {
-            // send all messages
-            for ( int i = 0; i < MESSAGE_COUNT; i++ )
-            {
-                ITextMessage msg;
-                try
-                {
-                    msg = _channel.CreateTextMessage(GetData(512 + 8 * i));
-                } catch ( Exception e )
-                {
-                    _logger.Error("Error creating message: " + e, e);
-                    break;
-                }
-                _publisher.Send(msg);
-            }
-            
-            _logger.Debug("All messages sent");
-            // receive all messages
-            for ( int i = 0; i < MESSAGE_COUNT; i++ )
-            {
-                try
-                {
-                    IMessage msg = _consumer.Receive();
-                    Assert.IsNotNull(msg);
-                } catch ( Exception e )
-                {
-                    _logger.Error("Error receiving message: " + e, e);
-                    Assert.Fail(e.ToString());
-                }
-            }
-        }
-        
-        [Test]
-        public void ReceiveWithTimeout()
-        {
-            ITextMessage msg = _channel.CreateTextMessage(GetData(512 + 8));
-            _publisher.Send(msg);
-            
-            IMessage recvMsg = _consumer.Receive();
-            Assert.IsNotNull(recvMsg);
-            // empty queue, should timeout
-            Assert.IsNull(_consumer.Receive(1000));
-        }
-    }
-}
-- 
cgit v1.2.1