Struct solace_rs::session::Session

pub struct Session<'session> { /* private fields */ }

Implementations

impl<'session> Session<'session>

pub fn publish(&self, message: OutboundMessage) -> Result<(), SessionError>

pub fn subscribe<T>(&self, topic: T) -> Result<(), SessionError>

where T: Into<Vec<u8>>,

pub fn unsubscribe<T>(&self, topic: T) -> Result<(), SessionError>

where T: Into<Vec<u8>>,

pub fn cache_session<N>( self, cache_name: N, max_message: Option<u64>, max_age: Option<u64>, timeout_ms: Option<u64> ) -> Result<CacheSession<'session>, SessionError>

where N: Into<Vec<u8>>,

Trait Implementations

impl Drop for Session<'_>

fn drop(&mut self)

Executes the destructor for this type.

impl Send for Session<'_>

impl Sync for Session<'_>