message.h

 
#pragma once
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include <pulsar/defines.h>
#include <stddef.h>
#include <stdint.h>
 
#include "string_map.h"
 
typedef struct _pulsar_message pulsar_message_t;
typedef struct _pulsar_message_id pulsar_message_id_t;
 
PULSAR_PUBLIC pulsar_message_t *pulsar_message_create();
PULSAR_PUBLIC void pulsar_message_copy(const pulsar_message_t *from, pulsar_message_t *to);
PULSAR_PUBLIC void pulsar_message_free(pulsar_message_t *message);

 
PULSAR_PUBLIC void pulsar_message_set_content(pulsar_message_t *message, const void *data, size_t size);

PULSAR_PUBLIC void pulsar_message_set_allocated_content(pulsar_message_t *message, void *data, size_t size);
 
PULSAR_PUBLIC void pulsar_message_set_property(pulsar_message_t *message, const char *name,
                                               const char *value);

PULSAR_PUBLIC void pulsar_message_set_partition_key(pulsar_message_t *message, const char *partitionKey);

PULSAR_PUBLIC void pulsar_message_set_ordering_key(pulsar_message_t *message, const char *orderingKey);

PULSAR_PUBLIC void pulsar_message_set_event_timestamp(pulsar_message_t *message, uint64_t eventTimestamp);

PULSAR_PUBLIC void pulsar_message_set_sequence_id(pulsar_message_t *message, int64_t sequenceId);

PULSAR_PUBLIC void pulsar_message_set_deliver_after(pulsar_message_t *message, uint64_t delayMillis);

PULSAR_PUBLIC void pulsar_message_set_deliver_at(pulsar_message_t *message, uint64_t deliveryTimestampMillis);

PULSAR_PUBLIC void pulsar_message_set_replication_clusters(pulsar_message_t *message, const char **clusters,
                                                           size_t size);

PULSAR_PUBLIC void pulsar_message_disable_replication(pulsar_message_t *message, int flag);

PULSAR_PUBLIC void pulsar_message_set_null_value(pulsar_message_t *message);


PULSAR_PUBLIC pulsar_string_map_t *pulsar_message_get_properties(pulsar_message_t *message);

PULSAR_PUBLIC int pulsar_message_has_property(pulsar_message_t *message, const char *name);

PULSAR_PUBLIC const char *pulsar_message_get_property(pulsar_message_t *message, const char *name);

PULSAR_PUBLIC const void *pulsar_message_get_data(pulsar_message_t *message);

PULSAR_PUBLIC uint32_t pulsar_message_get_length(pulsar_message_t *message);

PULSAR_PUBLIC pulsar_message_id_t *pulsar_message_get_message_id(pulsar_message_t *message);

PULSAR_PUBLIC const char *pulsar_message_get_partitionKey(pulsar_message_t *message);
PULSAR_PUBLIC int pulsar_message_has_partition_key(pulsar_message_t *message);

PULSAR_PUBLIC const char *pulsar_message_get_orderingKey(pulsar_message_t *message);
PULSAR_PUBLIC int pulsar_message_has_ordering_key(pulsar_message_t *message);

PULSAR_PUBLIC uint64_t pulsar_message_get_publish_timestamp(pulsar_message_t *message);

PULSAR_PUBLIC uint64_t pulsar_message_get_event_timestamp(pulsar_message_t *message);
 
PULSAR_PUBLIC const char *pulsar_message_get_topic_name(pulsar_message_t *message);
 
PULSAR_PUBLIC int pulsar_message_get_redelivery_count(pulsar_message_t *message);
 
PULSAR_PUBLIC int pulsar_message_has_schema_version(pulsar_message_t *message);
 
PULSAR_PUBLIC const char *pulsar_message_get_schemaVersion(pulsar_message_t *message);
 
PULSAR_PUBLIC void pulsar_message_set_schema_version(pulsar_message_t *message, const char *schemaVersion);

PULSAR_PUBLIC const char *pulsar_message_get_producer_name(pulsar_message_t *message);

PULSAR_PUBLIC const char *pulsar_message_get_replicated_from(pulsar_message_t *message);

PULSAR_PUBLIC int pulsar_message_has_null_value(pulsar_message_t *message);
 
#ifdef __cplusplus
}
#endif