summaryrefslogtreecommitdiff
path: root/Final/cpp/tests/SimpleTestCaseBase.h
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2007-11-20 13:59:54 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2007-11-20 13:59:54 +0000
commitbcd011a10c0db4ffc6f78380c548d673e270e000 (patch)
treeae6961f122221a7ce574e10895be8abcca044f12 /Final/cpp/tests/SimpleTestCaseBase.h
parent5b7a0ca8896f20c85f176cd178735554833bcefc (diff)
downloadqpid-python-bcd011a10c0db4ffc6f78380c548d673e270e000.tar.gz
backing up the previous tag
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/tags/M2@596673 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'Final/cpp/tests/SimpleTestCaseBase.h')
-rw-r--r--Final/cpp/tests/SimpleTestCaseBase.h187
1 files changed, 0 insertions, 187 deletions
diff --git a/Final/cpp/tests/SimpleTestCaseBase.h b/Final/cpp/tests/SimpleTestCaseBase.h
deleted file mode 100644
index 66f87ae42a..0000000000
--- a/Final/cpp/tests/SimpleTestCaseBase.h
+++ /dev/null
@@ -1,187 +0,0 @@
-#ifndef _SimpleTestCaseBase_
-#define _SimpleTestCaseBase_
-/*
- *
- * 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.
- *
- */
-
-#include <memory>
-#include <sstream>
-
-#include <ClientChannel.h>
-#include <ClientMessage.h>
-#include <Connection.h>
-#include <Exception.h>
-#include <MessageListener.h>
-#include "TestCase.h"
-#include "TestUtils.h"
-
-#define DEFAULT_INTEROP_MESSAGE_SIZE 256
-
-namespace qpid {
-
-using namespace qpid::client;
-
-/**
- * SimpleTestCaseBase defines a base implementation of TestCase class. It provides the ability, to wrap a 'Worker' that
- * the work of running a test case is delegated too. There are two kinds of workers provided, a base worker, which is abstract
- * and may be extended to provide the tests behaviour, and a 'Sender' worker, that provides the ability to send a number
- * of messages.
- *
- * <p/>A worker encapsulates a connection, a channel, an expected number of messages to be sent or received, and a count of the
- * number actually sent or received.
- */
-class SimpleTestCaseBase : public TestCase
-{
-protected:
-
- /**
- * A worker encapsulates a connection, channel, an expected number of messages to be sent or received, and a count of the
- * number actually sent or received.
- *
- * <p/>Worker is an abstract class, extend it to do something usefull on the init() and start() methods.
- *
- * <p/>A worker is created from a set of TestOptions, which captures a number of configuration parameters, such as the
- * broker to connect to.
- *
- * TODO: Extend TestOptions to capture the full set of creation properties for distributed tests.
- */
- class Worker
- {
- protected:
- /** Holds the connection for the worker to send/receive over. */
- client::Connection connection;
-
- /** Holds the channel for the worker to send/receive over. */
- client::Channel channel;
-
- /** Holds the expected number of messages for the worker to send or received. */
- const int messages;
-
- /** Holds a count of the number of messages actually sent or received. */
- int count;
-
- public:
-
- /**
- * Creates a worker using the specified options, for the given expected message count.
- *
- * @param options The creation options.
- * @param messages The number of messages expected to be sent or received.
- */
- Worker(TestOptions& options, const int messages);
- virtual ~Worker(){}
-
- /** Should be called ahead of start() to configure the worker. */
- virtual void init() = 0;
-
- /** Starts the workers test activity. */
- virtual void start() = 0;
-
- /** Terminates the workers test activity. */
- virtual void stop();
-
- /** Gets the count of messages actually sent or received by the worker. */
- virtual int getCount();
- };
-
- /**
- * Sender is a worker that sends the expected number of messages to be sent, over the configured exchange, using a
- * specified routing key.
- */
- class Sender : public Worker
- {
- /** Holds the exchange to send message to. */
- const Exchange& exchange;
-
- /** Holds the routing key for the messages. */
- const std::string key;
-
- /** Holds the message size parameter for all test messages. */
- const int messageSize;
-
- public:
-
- /**
- * Creates a sender using the specified options, for the given expected message count, exchange and routing key.
- *
- * @param options The creation options.
- * @param exchange The exchange to send the messages over.
- * @param key The routing key for the messages.
- * @param messages The number of messages expected to be sent or received.
- */
- Sender(TestOptions& options, const Exchange& exchange, const std::string& key, const int messages);
-
- /**
- * Creates a sender using the specified options, for the given expected message count, exchange and routing key.
- *
- * @param options The creation options.
- * @param exchange The exchange to send the messages over.
- * @param key The routing key for the messages.
- * @param messages The number of messages expected to be sent or received.
- * @param messageSize The size of test messages to send.
- */
- Sender(TestOptions& options, const Exchange& exchange, const std::string& key, const int messages, const int messageSize);
-
- /**
- * Starts the underlying channel.
- */
- void init();
-
- /**
- * Sends the specified number of messages over the connection, channel and exchange using the configured routing key.
- */
- void start();
- };
-
- /** Holds a pointer to the encapsulated worker. */
- std::auto_ptr<Worker> worker;
-
-public:
-
- virtual ~SimpleTestCaseBase() {}
-
- /**
- * Assigns the role to be played by this test case. The test parameters are fully specified in the
- * assignment messages filed table.
- *
- * @param role The role to be played; sender or receiver.
- * @param assignRoleMessage The role assingment messages field table, contains the full test parameters.
- * @param options Additional test options.
- */
- virtual void assign(const std::string& role, framing::FieldTable& params, TestOptions& options) = 0;
-
- /**
- * Starts the worker.
- */
- void start();
-
- /**
- * Stops the worker.
- */
- void stop();
-
- /**
- * Reports the number of messages sent or received.
- */
- void report(client::Message& report);
-};
-}
-
-#endif