summaryrefslogtreecommitdiff
path: root/trunk/qpid/wcf/test/Apache/Qpid/Test/Channel/Functional/MessageClient.cs
diff options
context:
space:
mode:
Diffstat (limited to 'trunk/qpid/wcf/test/Apache/Qpid/Test/Channel/Functional/MessageClient.cs')
-rw-r--r--trunk/qpid/wcf/test/Apache/Qpid/Test/Channel/Functional/MessageClient.cs101
1 files changed, 0 insertions, 101 deletions
diff --git a/trunk/qpid/wcf/test/Apache/Qpid/Test/Channel/Functional/MessageClient.cs b/trunk/qpid/wcf/test/Apache/Qpid/Test/Channel/Functional/MessageClient.cs
deleted file mode 100644
index 8f867551b1..0000000000
--- a/trunk/qpid/wcf/test/Apache/Qpid/Test/Channel/Functional/MessageClient.cs
+++ /dev/null
@@ -1,101 +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.
-*/
-
-namespace Apache.Qpid.Test.Channel.Functional
-{
- using System;
- using System.Reflection;
- using System.ServiceModel;
- using System.ServiceModel.Channels;
-
- public class MessageClient
- {
- public int NumberOfMessages
- {
- get;
- set;
- }
-
- public int NumberOfIterations
- {
- get;
- set;
- }
-
- public void RunClient<TServiceContract>(EndpointAddress address)
- {
- Binding amqpBinding = Util.GetBinding();
- Type proxyType = typeof(TServiceContract);
- MethodInfo helloMethod = proxyType.GetMethod("Hello");
- MethodInfo goodbyeMethod = proxyType.GetMethod("Goodbye");
-
- string[] messages = new string[this.NumberOfMessages];
- for (int i = 0; i < this.NumberOfMessages; ++i)
- {
- messages[i] = "Message " + i;
- }
-
- for (int i = 0; i < this.NumberOfIterations; ++i)
- {
- this.CreateChannelAndSendMessages<TServiceContract>(address, amqpBinding, helloMethod, goodbyeMethod, messages);
- }
- }
-
- public void RunInteropClient<TServiceContract>(EndpointAddress address)
- {
- Binding amqpBinding = Util.GetBinding();
- Type proxyType = typeof(TServiceContract);
- MethodInfo helloMethod = proxyType.GetMethod("Hello");
-
- Message[] messages = new Message[this.NumberOfMessages];
-
- for (int i = 0; i < this.NumberOfIterations; ++i)
- {
- this.CreateInteropChannelAndSendMessages<TServiceContract>(address, amqpBinding, helloMethod, this.NumberOfMessages);
- }
- }
-
- private void CreateChannelAndSendMessages<TServiceContract>(EndpointAddress address, Binding amqpBinding, MethodInfo helloMethod, MethodInfo goodbyeMethod, object[] messages)
- {
- ChannelFactory<TServiceContract> channelFactory = new ChannelFactory<TServiceContract>(amqpBinding, address);
- TServiceContract proxy = channelFactory.CreateChannel();
-
- foreach (object message in messages)
- {
- helloMethod.Invoke(proxy, new object[] { message });
- }
-
- goodbyeMethod.Invoke(proxy, new object[0]);
- channelFactory.Close();
- }
-
- private void CreateInteropChannelAndSendMessages<TServiceContract>(EndpointAddress address, Binding amqpBinding, MethodInfo helloMethod, int messageCount)
- {
- ChannelFactory<TServiceContract> channelFactory = new ChannelFactory<TServiceContract>(amqpBinding, address);
- TServiceContract proxy = channelFactory.CreateChannel();
-
- for (int i = 0; i < messageCount; i++)
- {
- helloMethod.Invoke(proxy, new object[] { Message.CreateMessage(MessageVersion.Soap12WSAddressing10, "*") });
- }
-
- channelFactory.Close();
- }
- }
-}