Trait little_stomper::client::Client[−][src]

pub trait Client: Subscriber + Sender + Sync + Send {
    fn connect_callback(&self, result: Result<(), StomperError>);
    fn error(&self, message: &str);
    fn into_sender(self: Arc<Self>) -> Arc<dyn Sender>;
    fn into_subscriber(self: Arc<Self>) -> Arc<dyn Subscriber>;
}

Expand description

A proxy for a client which can subscribe to destinations, receive messages and send messages.

Note that a client must also implement destinations::Subscriber and destinations::Sender, which define the bulk of the API.

Required methods

fn connect_callback(&self, result: Result<(), StomperError>)[src]

A callback which is called when a client has connected, with the result of processing to date.

fn error(&self, message: &str)[src]

Allows error messages to be send to the client

fn into_sender(self: Arc<Self>) -> Arc<dyn Sender>[src]

Exposes self as a Sender.

fn into_subscriber(self: Arc<Self>) -> Arc<dyn Subscriber>[src]

Exposes self as a Subscriber.

Implementors

impl Client for AsyncStompClient[src]

fn connect_callback(&self, result: Result<(), StomperError>)[src]

fn into_sender(self: Arc<Self>) -> Arc<dyn Sender + 'static>[src]

fn into_subscriber(self: Arc<Self>) -> Arc<dyn Subscriber + 'static>[src]

fn error(&self, message: &str)[src]