Author: gsim
Date: Thu Mar 28 15:01:21 2013
New Revision: 1462139
URL: http://svn.apache.org/r1462139
Log:
QPID-4675: Allow receivers from direct exchanges without a subject filter
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp?rev=1462139&r1=1462138&r2=1462139&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp Thu Mar 28 15:01:21
2013
@@ -235,12 +235,10 @@ void Session::setupOutgoing(pn_link_t* l
if (filter.hasSubjectFilter()) {
filter.bind(node.exchange, queue);
filter.write(pn_terminus_filter(pn_link_source(link)));
- } else if (node.exchange->getType() == FanOutExchange::typeName) {
- node.exchange->bind(queue, std::string(), 0);
} else if (node.exchange->getType() == TopicExchange::typeName) {
node.exchange->bind(queue, "#", 0);
} else {
- throw qpid::Exception("Exchange type requires a filter: " +
node.exchange->getType());/*not-supported?*/
+ node.exchange->bind(queue, std::string(), 0);
}
boost::shared_ptr<Outgoing> q(new OutgoingFromQueue(broker, name,
target, queue, link, *this, out, true));
outgoing[link] = q;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
