message_router.h

 
#pragma once
 
#include <pulsar/c/message.h>
#include <pulsar/defines.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef struct _pulsar_topic_metadata pulsar_topic_metadata_t;
 
typedef int (*pulsar_message_router)(pulsar_message_t *msg, pulsar_topic_metadata_t *topicMetadata,
                                     void *ctx);
 
PULSAR_PUBLIC int pulsar_topic_metadata_get_num_partitions(pulsar_topic_metadata_t *topicMetadata);
 
#ifdef __cplusplus
}
#endif