diff options
| author | Gordon Sim <gsim@apache.org> | 2013-11-12 13:42:36 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2013-11-12 13:42:36 +0000 |
| commit | 5f3ff3bcc03691d0646cd75d8408be284d8adee6 (patch) | |
| tree | d475768bd96b23ac17771b1b9d8617b2790d83e5 /cpp/src/tests/ExchangeTest.cpp | |
| parent | 3741945c58f6b835003bbdb978efa34ff6a681b5 (diff) | |
| download | qpid-python-5f3ff3bcc03691d0646cd75d8408be284d8adee6.tar.gz | |
QPID-5301: support autodeleted exchanges
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1541058 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/ExchangeTest.cpp')
| -rw-r--r-- | cpp/src/tests/ExchangeTest.cpp | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/cpp/src/tests/ExchangeTest.cpp b/cpp/src/tests/ExchangeTest.cpp index 8c2dbb21c8..df0684e832 100644 --- a/cpp/src/tests/ExchangeTest.cpp +++ b/cpp/src/tests/ExchangeTest.cpp @@ -158,12 +158,12 @@ QPID_AUTO_TEST_CASE(testIsBound) QPID_AUTO_TEST_CASE(testDeleteGetAndRedeclare) { ExchangeRegistry exchanges; - exchanges.declare("my-exchange", "direct", false, FieldTable()); + exchanges.declare("my-exchange", "direct", false, false, FieldTable()); exchanges.destroy("my-exchange"); try { exchanges.get("my-exchange"); } catch (const NotFoundException&) {} - std::pair<Exchange::shared_ptr, bool> response = exchanges.declare("my-exchange", "direct", false, FieldTable()); + std::pair<Exchange::shared_ptr, bool> response = exchanges.declare("my-exchange", "direct", false, false, FieldTable()); BOOST_CHECK_EQUAL(string("direct"), response.first->getType()); } @@ -174,7 +174,7 @@ QPID_AUTO_TEST_CASE(testSequenceOptions) char* buff = new char[10000]; framing::Buffer buffer(buff,10000); { - DirectExchange direct("direct1", false, args); + DirectExchange direct("direct1", false, false, args); DeliverableMessage msg1(MessageUtils::createMessage("e", "abc"), 0); DeliverableMessage msg2(MessageUtils::createMessage("e", "abc"), 0); @@ -188,9 +188,9 @@ QPID_AUTO_TEST_CASE(testSequenceOptions) BOOST_CHECK_EQUAL(2, msg2.getMessage().getAnnotation("qpid.msg_sequence").asInt64()); BOOST_CHECK_EQUAL(3, msg3.getMessage().getAnnotation("qpid.msg_sequence").asInt64()); - FanOutExchange fanout("fanout1", false, args); - HeadersExchange header("headers1", false, args); - TopicExchange topic ("topic1", false, args); + FanOutExchange fanout("fanout1", false, false, args); + HeadersExchange header("headers1", false, false, args); + TopicExchange topic ("topic1", false, false, args); // check other exchanges, that they preroute DeliverableMessage msg4(MessageUtils::createMessage("e", "abc"), 0); @@ -226,10 +226,10 @@ QPID_AUTO_TEST_CASE(testIVEOption) { FieldTable args; args.setInt("qpid.ive",1); - DirectExchange direct("direct1", false, args); - FanOutExchange fanout("fanout1", false, args); - HeadersExchange header("headers1", false, args); - TopicExchange topic ("topic1", false, args); + DirectExchange direct("direct1", false, false, args); + FanOutExchange fanout("fanout1", false, false, args); + HeadersExchange header("headers1", false, false, args); + TopicExchange topic ("topic1", false, false, args); qpid::types::Variant::Map properties; properties["routing-key"] = "abc"; |
