summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/tests/cluster_test.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2008-10-31 16:56:04 +0000
committerAlan Conway <aconway@apache.org>2008-10-31 16:56:04 +0000
commitf29a0d9787daffa72a381864ae057e189d547702 (patch)
tree722d4251bd577dbfc11b1daaa464e7455d167871 /qpid/cpp/src/tests/cluster_test.cpp
parent5d98492e5dde9e85451d2aae531336fce318c80a (diff)
downloadqpid-python-f29a0d9787daffa72a381864ae057e189d547702.tar.gz
Cluster returns connection exception for un-supported AMQP features.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@709474 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/cluster_test.cpp')
-rw-r--r--qpid/cpp/src/tests/cluster_test.cpp14
1 files changed, 14 insertions, 0 deletions
diff --git a/qpid/cpp/src/tests/cluster_test.cpp b/qpid/cpp/src/tests/cluster_test.cpp
index 63bd31ea1b..5f18d0ff90 100644
--- a/qpid/cpp/src/tests/cluster_test.cpp
+++ b/qpid/cpp/src/tests/cluster_test.cpp
@@ -220,6 +220,20 @@ class Sender {
uint16_t channel;
};
+QPID_AUTO_TEST_CASE(testUnsupported) {
+ ScopedSuppressLogging sl;
+ ClusterFixture cluster(1);
+ Client c0(cluster[0], "c0");
+ BOOST_CHECK_THROW(c0.session.txSelect(), Exception);
+ BOOST_CHECK(!c0.connection.isOpen());
+ Client c1(cluster[0], "c1");
+ BOOST_CHECK_THROW(c1.session.dtxCommit(), Exception);
+ Client c2(cluster[0], "c2");
+ Message m;
+ m.getDeliveryProperties().setTtl(1);
+ BOOST_CHECK_THROW(c2.session.messageTransfer(arg::content=m), Exception);
+}
+
QPID_AUTO_TEST_CASE(testUnacked) {
// Verify replication of unacknowledged messages.
ClusterFixture cluster(1);