pulsar-client-cpp
include
pulsar
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
32
class
MessageRoutingPolicy
{
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_
pulsar
Definition:
Authentication.h:31
pulsar::MessageRoutingPolicy
Definition:
MessageRoutingPolicy.h:32
pulsar::Message
Definition:
Message.h:42
Generated by
1.8.14