Cluster returns connection exception for un-supported AMQP features.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@709474 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 14 insertions, 0 deletions

diff --git a/cpp/src/tests/cluster_test.cpp b/cpp/src/tests/cluster_test.cpp
index 63bd31ea1b..5f18d0ff90 100644
--- a/cpp/src/tests/cluster_test.cpp
+++ b/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);