pulsar-client-cpp
MessageRoutingPolicy.h
1 
19 #ifndef PULSAR_MESSAGE_ROUTING_POLICY_HEADER_
20 #define PULSAR_MESSAGE_ROUTING_POLICY_HEADER_
21 #include "Message.h"
22 #include <boost/shared_ptr.hpp>
23 
24 #pragma GCC visibility push(default)
25 
26 /*
27  * Implement this interface to define custom policy giving message to
28  * partition mapping.
29  */
30 namespace pulsar {
31 
33  public:
34  virtual ~MessageRoutingPolicy() {}
35 
36  virtual int getPartition(const Message& msg) = 0;
37 };
38 
39 typedef boost::shared_ptr<MessageRoutingPolicy> MessageRoutingPolicyPtr;
40 }
41 
42 #pragma GCC visibility pop
43 
44 #endif // PULSAR_MESSAGE_ROUTING_POLICY_HEADER_
Definition: Authentication.h:31
Definition: MessageRoutingPolicy.h:32
Definition: Message.h:42