MessageRoutingPolicy.h

 
#ifndef PULSAR_MESSAGE_ROUTING_POLICY_HEADER_
#define PULSAR_MESSAGE_ROUTING_POLICY_HEADER_
 
#include <pulsar/defines.h>
#include <pulsar/DeprecatedException.h>
#include <pulsar/Message.h>
#include <pulsar/TopicMetadata.h>
#include <memory>
 
/*
 * Implement this interface to define custom policy giving message to
 * partition mapping.
 */
namespace pulsar {
 
class PULSAR_PUBLIC MessageRoutingPolicy {
   public:
    virtual ~MessageRoutingPolicy() {}
 
    virtual int getPartition(const Message& msg) {
        throw DeprecatedException(
            "Use int getPartition(const Message& msg,"
            " const TopicMetadata& topicMetadata)");
    }
 
    virtual int getPartition(const Message& msg, const TopicMetadata& topicMetadata) {
        return getPartition(msg);
    }
};
 
typedef std::shared_ptr<MessageRoutingPolicy> MessageRoutingPolicyPtr;
}  // namespace pulsar
 
#endif  // PULSAR_MESSAGE_ROUTING_POLICY_HEADER_