Struct solace_rs::session::Session

pub struct Session { /* private fields */ }

Implementations

impl 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, 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