Struct solace_rs::message::inbound::InboundMessage

pub struct InboundMessage { /* private fields */ }

Implementations

impl InboundMessage

pub fn get_receive_timestamp(&self) -> Result<Option<SystemTime>, SolaceError>

pub fn get_sender_id(&self) -> Result<Option<&str>, SolaceError>

pub fn is_discard_indication(&self) -> bool

Trait Implementations

impl Drop for InboundMessage

fn drop(&mut self)

Executes the destructor for this type.

impl From<*mut c_void> for InboundMessage

fn from(ptr: solClient_opaqueMsg_pt) -> Self

.

Safety

From a valid owned pointer. No other alias should exist for this pointer InboundMessage will try to free the ptr when it is destroyed

.

impl<'a> Message<'a> for InboundMessage

unsafe fn get_raw_message_ptr(&self) -> solClient_opaqueMsg_pt

.

fn get_payload(&'a self) -> Result<Option<&'a [u8]>, SolaceError>

fn get_application_message_id(&'a self) -> Option<&'a str>

fn get_application_msg_type(&'a self) -> Option<&'a str>

fn get_class_of_service(&'a self) -> Result<ClassOfService, SolaceError>

fn get_correlation_id(&'a self) -> Result<Option<&'a str>, SolaceError>

fn get_expiration(&'a self) -> i64

fn get_priority(&'a self) -> Result<Option<u8>, SolaceError>

fn get_sequence_number(&'a self) -> Result<Option<i64>, SolaceError>

fn get_destination(&'a self) -> Result<Option<MessageDestination>, SolaceError>

fn get_sender_timestamp(&'a self) -> Result<Option<SystemTime>, SolaceError>

fn get_user_data(&'a self) -> Result<Option<&'a [u8]>, SolaceError>

impl Send for InboundMessage