Function pulsar_sys::pulsar_producer_send

pub unsafe extern "C" fn pulsar_producer_send(
    producer: *mut pulsar_producer_t, 
    msg: *mut pulsar_message_t
) -> pulsar_result

Publish a message on the topic associated with this Producer.

This method will block until the message will be accepted and persisted by the broker. In case of errors, the client library will try to automatically recover and use a different broker.

If it wasn't possible to successfully publish the message within the sendTimeout, an error will be returned.

This method is equivalent to asyncSend() and wait until the callback is triggered.

@param msg message to publish @return ResultOk if the message was published successfully @return ResultWriteError if it wasn't possible to publish the message