pub struct Session { /* private fields */ }
Expand description
holds the native Session pointer
Implementations
sourceimpl 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
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for Session
impl Send for Session
impl Sync for Session
impl Unpin for Session
impl UnwindSafe for Session
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcefn clone_into(&self, target: &mut T)
fn clone_into(&self, target: &mut T)
🔬 This is a nightly-only experimental API. (
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more