pulsar-client-cpp
message_router.h
1 
20 #pragma once
21 
22 #include <pulsar/c/message.h>
23 #include <pulsar/defines.h>
24 
25 #ifdef __cplusplus
26 extern "C" {
27 #endif
28 
29 typedef struct _pulsar_topic_metadata pulsar_topic_metadata_t;
30 
31 typedef int (*pulsar_message_router)(pulsar_message_t *msg, pulsar_topic_metadata_t *topicMetadata,
32  void *ctx);
33 
34 PULSAR_PUBLIC int pulsar_topic_metadata_get_num_partitions(pulsar_topic_metadata_t *topicMetadata);
35 
36 #ifdef __cplusplus
37 }
38 #endif