pub struct Session { /* private fields */ }
Expand description
holds the native Session pointer
Implementations§
source§impl Session
impl Session
sourcepub fn queue_consumer(
&self,
destination: &Destination,
selector: Option<&str>
) -> Result<Consumer, Error>
pub fn queue_consumer(
&self,
destination: &Destination,
selector: Option<&str>
) -> Result<Consumer, Error>
open a message consumer for a queue
sourcepub fn topic_consumer(
&self,
destination: &Destination,
subscription_name: &str,
selector: Option<&str>
) -> Result<Consumer, Error>
pub fn topic_consumer(
&self,
destination: &Destination,
subscription_name: &str,
selector: Option<&str>
) -> Result<Consumer, Error>
open a message consumer for a topic
sourcepub fn topic_durable_consumer(
&self,
destination: &Destination,
durable_name: &str,
selector: Option<&str>
) -> Result<Consumer, Error>
pub fn topic_durable_consumer(
&self,
destination: &Destination,
durable_name: &str,
selector: Option<&str>
) -> Result<Consumer, Error>
open a durable message consumer for a topic
sourcepub fn send_message<M: Into<Message>>(
&self,
destination: &Destination,
message: M
) -> Result<(), Error>
pub fn send_message<M: Into<Message>>(
&self,
destination: &Destination,
message: M
) -> Result<(), Error>
sending a message to a destination (only queues are supported)
sourcepub fn request_reply<M: Into<Message>>(
&self,
destination: &Destination,
message: M,
timeout: i64
) -> Result<Option<Message>, Error>
pub fn request_reply<M: Into<Message>>(
&self,
destination: &Destination,
message: M,
timeout: i64
) -> Result<Option<Message>, Error>
request/reply