QPID-4558: Selectors for C++ broker

- Added in amqp 1.0 support that uses a filter for the selector
- This change requires at least qpid-proton 0.4 (or a lot of warning
  messages are produced by the broker)

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

1 files changed, 5 insertions, 0 deletions

diff --git a/qpid/cpp/src/qpid/broker/amqp/Outgoing.h b/qpid/cpp/src/qpid/broker/amqp/Outgoing.h
index a8450a48cf..7d845a1427 100644
--- a/qpid/cpp/src/qpid/broker/amqp/Outgoing.h
+++ b/qpid/cpp/src/qpid/broker/amqp/Outgoing.h
@@ -24,7 +24,9 @@
 #include "qpid/broker/amqp/Message.h"
 #include "qpid/broker/amqp/ManagedOutgoingLink.h"
 #include "qpid/broker/Consumer.h"
+
 #include <boost/shared_ptr.hpp>
+#include <boost/scoped_ptr.hpp>
 #include <boost/enable_shared_from_this.hpp>
 extern "C" {
 #include <proton/engine.h>
@@ -37,6 +39,7 @@ class OutputControl;
 namespace broker {
 class Broker;
 class Queue;
+class Selector;
 namespace amqp {
 class ManagedSession;
 template <class T>
@@ -61,6 +64,7 @@ class Outgoing : public qpid::broker::Consumer, public boost::enable_shared_from
   public:
     Outgoing(Broker&,boost::shared_ptr<Queue> q, pn_link_t* l, ManagedSession&, qpid::sys::OutputControl& o, bool topic);
     void setSubjectFilter(const std::string&);
+    void setSelectorFilter(const std::string&);
     void init();
     bool dispatch();
     void write(const char* data, size_t size);
@@ -102,6 +106,7 @@ class Outgoing : public qpid::broker::Consumer, public boost::enable_shared_from
     int outstanding;
     std::vector<char> buffer;
     std::string subjectFilter;
+    boost::scoped_ptr<Selector> selector;
 };
 }}} // namespace qpid::broker::amqp