summaryrefslogtreecommitdiff
path: root/qpid/dotnet/client-010/test/interop/TestCase.cs
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/dotnet/client-010/test/interop/TestCase.cs')
-rw-r--r--qpid/dotnet/client-010/test/interop/TestCase.cs96
1 files changed, 0 insertions, 96 deletions
diff --git a/qpid/dotnet/client-010/test/interop/TestCase.cs b/qpid/dotnet/client-010/test/interop/TestCase.cs
deleted file mode 100644
index 867f082000..0000000000
--- a/qpid/dotnet/client-010/test/interop/TestCase.cs
+++ /dev/null
@@ -1,96 +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.Collections.Generic;
-using System.IO;
-using System.Threading;
-using System.Xml;
-using common.org.apache.qpid.transport.util;
-using log4net.Config;
-using NUnit.Framework;
-using org.apache.qpid.client;
-using org.apache.qpid.transport;
-using org.apache.qpid.transport.util;
-using test.Helpers;
-
-namespace test.interop
-{
- [TestFixture]
-
- public class TestCase
- {
- private readonly Dictionary<string,string> _properties = new Dictionary<string, string>();
- private Client _client;
-
- [TestFixtureSetUp]
- public void Init()
- {
- var properties = ConfigHelpers.LoadConfig();
- // create a client and connect to the broker
- _client = new Client();
- _client.Connect(properties["Host"], Convert.ToInt16(properties["Port"]), properties["VirtualHost"],
- properties["Username"], properties["Password"]);
-
- }
-
- [TestFixtureTearDown]
- public void Cleanup()
- {
- // Note : breaks the Resharper nunit test runner. It blocks on the Monitor.WaitAll()
- // Certainly a problem with the threading context..
- //_client.Close();
- }
-
- public Client Client
- {
- get{ return _client;}
- }
-
- public Dictionary<string,string> Properties
- {
- get { return _properties; }
- }
-
-
- public class SyncListener : IMessageListener
- {
- private static readonly Logger _log = Logger.Get(typeof(SyncListener));
- private readonly CircularBuffer<IMessage> _buffer;
- private readonly RangeSet _range = new RangeSet();
- private readonly IClientSession _session;
-
- public SyncListener(IClientSession session, CircularBuffer<IMessage> buffer)
- {
- _buffer = buffer;
- _session = session;
- }
-
- public void MessageTransfer(IMessage m)
- {
- _range.Clear();
- _range.Add(m.Id);
- _session.MessageAccept(_range);
- _buffer.Enqueue(m);
- }
- }
- }
-}