[−][src]Function pulsar_sys::pulsar_reader_read_next_with_timeout
pub unsafe extern "C" fn pulsar_reader_read_next_with_timeout(
reader: *mut pulsar_reader_t,
msg: *mut *mut pulsar_message_t,
timeoutMs: c_int
) -> pulsar_result
Read a single message
@param msg a non-const reference where the received message will be copied @param timeoutMs the receive timeout in milliseconds @return ResultOk if a message was received @return ResultTimeout if the receive timeout was triggered @return ResultInvalidConfiguration if a message listener had been set in the configuration