Struct tibco_ems::Consumer

pub struct Consumer { /* private fields */ }

holds the native Consumer pointer

Implementations

impl Consumer

pub fn receive_message(
    &self,
    wait_time_ms: Option<i64>
) -> Result<Option<Message>, Error>

receive messages from a consumer

function returns after wait time with a Message or None a wait time of None blocks until a message is available

pub fn receive_text_message(
    &self,
    wait_time_ms: Option<i64>
) -> Result<Option<TextMessage>, Error>

receive text messages from a consumer

function returns after wait time with a Message or None a wait time of None blocks until a message is available

pub fn receive_bytes_message(
    &self,
    wait_time_ms: Option<i64>
) -> Result<Option<BytesMessage>, Error>

receive bytes messages from a consumer

function returns after wait time with a Message or None a wait time of None blocks until a message is available

pub fn receive_map_message(
    &self,
    wait_time_ms: Option<i64>
) -> Result<Option<MapMessage>, Error>

receive map messages from a consumer

function returns after wait time with a Message or None a wait time of None blocks until a message is available

pub fn receive_object_message(
    &self,
    wait_time_ms: Option<i64>
) -> Result<Option<ObjectMessage>, Error>

receive object messages from a consumer

function returns after wait time with a Message or None a wait time of None blocks until a message is available

Trait Implementations

impl Clone for Consumer

fn clone(&self) -> Consumer

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Consumer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Copy for Consumer