Struct tibco_ems::Session [−][src]
pub struct Session { /* fields omitted */ }
Expand description
holds the native Session pointer
Implementations
pub fn queue_consumer(
&self,
destination: &Destination,
selector: Option<&str>
) -> Result<Consumer, Error>
[src]
pub fn queue_consumer(
&self,
destination: &Destination,
selector: Option<&str>
) -> Result<Consumer, Error>
[src]open a message consumer for a queue
pub fn topic_consumer(
&self,
destination: &Destination,
subscription_name: &str,
selector: Option<&str>
) -> Result<Consumer, Error>
[src]
pub fn topic_consumer(
&self,
destination: &Destination,
subscription_name: &str,
selector: Option<&str>
) -> Result<Consumer, Error>
[src]open a message consumer for a topic
pub fn topic_durable_consumer(
&self,
destination: &Destination,
durable_name: &str,
selector: Option<&str>
) -> Result<Consumer, Error>
[src]
pub fn topic_durable_consumer(
&self,
destination: &Destination,
durable_name: &str,
selector: Option<&str>
) -> Result<Consumer, Error>
[src]open a durable message consumer for a topic
pub fn send_message<M: Into<Message>>(
&self,
destination: &Destination,
message: M
) -> Result<(), Error>
[src]
pub fn send_message<M: Into<Message>>(
&self,
destination: &Destination,
message: M
) -> Result<(), Error>
[src]sending a message to a destination (only queues are supported)
pub fn request_reply<M: Into<Message>>(
&self,
destination: &Destination,
message: M,
timeout: i64
) -> Result<Option<Message>, Error>
[src]
pub fn request_reply<M: Into<Message>>(
&self,
destination: &Destination,
message: M,
timeout: i64
) -> Result<Option<Message>, Error>
[src]request/reply
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for Session
impl UnwindSafe for Session
Blanket Implementations
Mutably borrows from an owned value. Read more