[−][src]Function pulsar_sys::pulsar_message_set_sequence_id
pub unsafe extern "C" fn pulsar_message_set_sequence_id(
message: *mut pulsar_message_t,
sequenceId: i64
)
Specify a custom sequence id for the message being published.
The sequence id can be used for deduplication purposes and it needs to follow these rules:
sequenceId >= 0
- Sequence id for a message needs to be greater than sequence id for earlier messages:
sequenceId(N+1) > sequenceId(N)
- It's not necessary for sequence ids to be consecutive. There can be holes between messages. Eg. the
sequenceId
could represent an offset or a cumulative size.
@param sequenceId the sequence id to assign to the current message