[−][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:

  1. sequenceId >= 0
  2. Sequence id for a message needs to be greater than sequence id for earlier messages: sequenceId(N+1) > sequenceId(N)
  3. 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