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 | b955a41e69f69a1ada69c780d9fb7260c0bfc3f2 (patch) | |
| tree | 4adb557c6b9325233acf2b48961e174325e28424 /qpid/cpp/src/tests/ExchangeTest.cpp | |
| parent | 50595b9c333b08327462fa3693a5ba4cdced76e6 (diff) | |
| download | qpid-python-b955a41e69f69a1ada69c780d9fb7260c0bfc3f2.tar.gz | |
QPID-5301: support autodeleted exchanges
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1541058 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/ExchangeTest.cpp')
| -rw-r--r-- | qpid/cpp/src/tests/ExchangeTest.cpp | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/qpid/cpp/src/tests/ExchangeTest.cpp b/qpid/cpp/src/tests/ExchangeTest.cpp index 8c2dbb21c8..df0684e832 100644 --- a/qpid/cpp/src/tests/ExchangeTest.cpp +++ b/qpid/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"; |
