qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From g...@apache.org
Subject svn commit: r1462139 - /qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp
Date Thu, 28 Mar 2013 15:01:22 GMT
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: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message