summaryrefslogtreecommitdiff
path: root/cpp/src/tests
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-02-21 17:40:42 +0000
committerGordon Sim <gsim@apache.org>2008-02-21 17:40:42 +0000
commit3767d7e49e80c268c60ee247b3526b986eb7fc17 (patch)
tree36f0c9487e54705530be26271de7e52676bad524 /cpp/src/tests
parent5f06a953368f7f41dd8ab94a6775fcd9b5c99792 (diff)
downloadqpid-python-3767d7e49e80c268c60ee247b3526b986eb7fc17.tar.gz
Start moving towards final 0-10 spec:
* marked preview spec as 99-0 to distinguish it from 0-10 (which will now be used for the final version) * modified python client to treat 99-0 as 0-10 for now * modified broker to have two paths for the two different versions: 99-0 uses PreviewConnection, PreviewConnectionHandler and PreviewSessionHandler which are straight copy & pastes of the Connection, ConnectionHandler and SessionHandler now associated with 0-10 (so we can migrate the 0-10 path to the final spec without affecting clients working with the preview version) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@629883 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests')
-rw-r--r--cpp/src/tests/BrokerFixture.h4
-rw-r--r--cpp/src/tests/ClientSessionTest.cpp4
-rw-r--r--cpp/src/tests/client_test.cpp4
-rw-r--r--cpp/src/tests/latencytest.cpp4
-rw-r--r--cpp/src/tests/perftest.cpp4
-rw-r--r--cpp/src/tests/topic_listener.cpp10
-rw-r--r--cpp/src/tests/topic_publisher.cpp10
-rw-r--r--cpp/src/tests/txtest.cpp4
8 files changed, 22 insertions, 22 deletions
diff --git a/cpp/src/tests/BrokerFixture.h b/cpp/src/tests/BrokerFixture.h
index 9fcdb57a99..fd350b77fe 100644
--- a/cpp/src/tests/BrokerFixture.h
+++ b/cpp/src/tests/BrokerFixture.h
@@ -27,7 +27,7 @@
#include "qpid/broker/Broker.h"
#include "qpid/client/Connection.h"
#include "qpid/client/ConnectionImpl.h"
-#include "qpid/client/Session_0_10.h"
+#include "qpid/client/Session.h"
#include "qpid/client/SubscriptionManager.h"
/**
@@ -86,7 +86,7 @@ struct ProxyConnection : public qpid::client::Connection {
template <class ConnectionType>
struct SessionFixtureT : BrokerFixture {
ConnectionType connection;
- qpid::client::Session_0_10 session;
+ qpid::client::Session session;
qpid::client::SubscriptionManager subs;
qpid::client::LocalQueue lq;
diff --git a/cpp/src/tests/ClientSessionTest.cpp b/cpp/src/tests/ClientSessionTest.cpp
index c299837f86..7a997db327 100644
--- a/cpp/src/tests/ClientSessionTest.cpp
+++ b/cpp/src/tests/ClientSessionTest.cpp
@@ -24,7 +24,7 @@
#include "qpid/sys/Monitor.h"
#include "qpid/sys/Thread.h"
#include "qpid/sys/Runnable.h"
-#include "qpid/client/Session_0_10.h"
+#include "qpid/client/Session.h"
#include "qpid/framing/TransferContent.h"
#include "qpid/framing/reply_exceptions.h"
@@ -52,7 +52,7 @@ struct DummyListener : public sys::Runnable, public MessageListener {
uint expected;
Dispatcher dispatcher;
- DummyListener(Session_0_10& session, const string& n, uint ex) :
+ DummyListener(Session& session, const string& n, uint ex) :
name(n), expected(ex), dispatcher(session) {}
void run()
diff --git a/cpp/src/tests/client_test.cpp b/cpp/src/tests/client_test.cpp
index 84fc9434de..bd2a541c92 100644
--- a/cpp/src/tests/client_test.cpp
+++ b/cpp/src/tests/client_test.cpp
@@ -31,7 +31,7 @@
#include "TestOptions.h"
#include "qpid/client/Connection.h"
#include "qpid/client/Message.h"
-#include "qpid/client/Session_0_10.h"
+#include "qpid/client/Session.h"
#include "qpid/framing/FrameSet.h"
#include "qpid/framing/MessageTransferBody.h"
@@ -92,7 +92,7 @@ int main(int argc, char** argv)
//Create and open a session on the connection through which
//most functionality is exposed:
- Session_0_10 session = connection.newSession(ASYNC);
+ Session session = connection.newSession(ASYNC);
if (opts.trace) std::cout << "Opened session." << std::endl;
diff --git a/cpp/src/tests/latencytest.cpp b/cpp/src/tests/latencytest.cpp
index 86200054d8..2b44a5477a 100644
--- a/cpp/src/tests/latencytest.cpp
+++ b/cpp/src/tests/latencytest.cpp
@@ -30,7 +30,7 @@
#include "TestOptions.h"
#include "qpid/client/Connection.h"
#include "qpid/client/Message.h"
-#include "qpid/client/Session_0_10.h"
+#include "qpid/client/Session.h"
#include "qpid/client/SubscriptionManager.h"
using namespace qpid;
@@ -98,7 +98,7 @@ class Client : public Runnable
{
protected:
Connection connection;
- Session_0_10 session;
+ Session session;
Thread thread;
string queue;
diff --git a/cpp/src/tests/perftest.cpp b/cpp/src/tests/perftest.cpp
index bc638635da..b950e432f5 100644
--- a/cpp/src/tests/perftest.cpp
+++ b/cpp/src/tests/perftest.cpp
@@ -21,7 +21,7 @@
#include "TestOptions.h"
-#include "qpid/client/Session_0_10.h"
+#include "qpid/client/Session.h"
#include "qpid/client/SubscriptionManager.h"
#include "qpid/client/Connection.h"
#include "qpid/client/Completion.h"
@@ -191,7 +191,7 @@ Opts opts;
struct Client : public Runnable {
Connection connection;
- Session_0_10 session;
+ Session session;
Thread thread;
Client() {
diff --git a/cpp/src/tests/topic_listener.cpp b/cpp/src/tests/topic_listener.cpp
index ec73f3cbe0..e5e7d24112 100644
--- a/cpp/src/tests/topic_listener.cpp
+++ b/cpp/src/tests/topic_listener.cpp
@@ -35,7 +35,7 @@
#include "TestOptions.h"
#include "qpid/client/Connection.h"
#include "qpid/client/MessageListener.h"
-#include "qpid/client/Session_0_10.h"
+#include "qpid/client/Session.h"
#include "qpid/client/SubscriptionManager.h"
#include "qpid/sys/Time.h"
#include "qpid/framing/FieldValue.h"
@@ -53,7 +53,7 @@ using namespace std;
* defined.
*/
class Listener : public MessageListener{
- Session_0_10& session;
+ Session& session;
SubscriptionManager& mgr;
const string responseQueue;
const bool transactional;
@@ -64,7 +64,7 @@ class Listener : public MessageListener{
void shutdown();
void report();
public:
- Listener(Session_0_10& session, SubscriptionManager& mgr, const string& reponseQueue, bool tx);
+ Listener(Session& session, SubscriptionManager& mgr, const string& reponseQueue, bool tx);
virtual void received(Message& msg);
};
@@ -101,7 +101,7 @@ int main(int argc, char** argv){
else {
Connection connection(args.trace);
args.open(connection);
- Session_0_10 session = connection.newSession(ASYNC);
+ Session session = connection.newSession(ASYNC);
if (args.transactional) {
session.txSelect();
}
@@ -144,7 +144,7 @@ int main(int argc, char** argv){
return 1;
}
-Listener::Listener(Session_0_10& s, SubscriptionManager& m, const string& _responseq, bool tx) :
+Listener::Listener(Session& s, SubscriptionManager& m, const string& _responseq, bool tx) :
session(s), mgr(m), responseQueue(_responseq), transactional(tx), init(false), count(0){}
void Listener::received(Message& message){
diff --git a/cpp/src/tests/topic_publisher.cpp b/cpp/src/tests/topic_publisher.cpp
index 24a4fc6752..2271849c35 100644
--- a/cpp/src/tests/topic_publisher.cpp
+++ b/cpp/src/tests/topic_publisher.cpp
@@ -37,7 +37,7 @@
#include "TestOptions.h"
#include "qpid/client/Connection.h"
#include "qpid/client/MessageListener.h"
-#include "qpid/client/Session_0_10.h"
+#include "qpid/client/Session.h"
#include "qpid/client/SubscriptionManager.h"
#include "qpid/sys/Monitor.h"
#include <unistd.h>
@@ -56,7 +56,7 @@ using namespace std;
* back by the subscribers.
*/
class Publisher {
- Session_0_10& session;
+ Session& session;
SubscriptionManager mgr;
LocalQueue queue;
const string controlTopic;
@@ -66,7 +66,7 @@ class Publisher {
string generateData(int size);
public:
- Publisher(Session_0_10& session, const string& controlTopic, bool tx, bool durable);
+ Publisher(Session& session, const string& controlTopic, bool tx, bool durable);
int64_t publish(int msgs, int listeners, int size);
void terminate();
};
@@ -107,7 +107,7 @@ int main(int argc, char** argv) {
else {
Connection connection(args.trace);
args.open(connection);
- Session_0_10 session = connection.newSession(ASYNC);
+ Session session = connection.newSession(ASYNC);
if (args.transactional) {
session.txSelect();
}
@@ -150,7 +150,7 @@ int main(int argc, char** argv) {
return 1;
}
-Publisher::Publisher(Session_0_10& _session, const string& _controlTopic, bool tx, bool d) :
+Publisher::Publisher(Session& _session, const string& _controlTopic, bool tx, bool d) :
session(_session), mgr(session), controlTopic(_controlTopic), transactional(tx), durable(d)
{
mgr.subscribe(queue, "response");
diff --git a/cpp/src/tests/txtest.cpp b/cpp/src/tests/txtest.cpp
index f7776dee8d..4c5814986c 100644
--- a/cpp/src/tests/txtest.cpp
+++ b/cpp/src/tests/txtest.cpp
@@ -28,7 +28,7 @@
#include "TestOptions.h"
#include "qpid/client/Connection.h"
#include "qpid/client/Message.h"
-#include "qpid/client/Session_0_10.h"
+#include "qpid/client/Session.h"
#include "qpid/client/SubscriptionManager.h"
using namespace qpid;
@@ -96,7 +96,7 @@ Args opts;
struct Client
{
Connection connection;
- Session_0_10 session;
+ Session session;
Client()
{