Trait little_stomper::destinations::Subscriber

source · 
pub trait Subscriber: Send + Sync + Debug {
    // Required methods
    fn subscribe_callback(
        &self,
        destination: DestinationId,
        suscriber_sub_id: Option<SubscriptionId>,
        result: Result<SubscriptionId, StomperError>
    );
    fn unsubscribe_callback(
        &self,
        subscriber_sub_id: Option<SubscriptionId>,
        result: Result<SubscriptionId, StomperError>
    );
    fn send(
        &self,
        subscription: SubscriptionId,
        suscriber_sub_id: Option<SubscriptionId>,
        message: OutboundMessage
    ) -> Result<(), StomperError>;
}

Required Methods§

source

fn subscribe_callback( &self, destination: DestinationId, suscriber_sub_id: Option<SubscriptionId>, result: Result<SubscriptionId, StomperError> )

source

fn unsubscribe_callback( &self, subscriber_sub_id: Option<SubscriptionId>, result: Result<SubscriptionId, StomperError> )

source

fn send( &self, subscription: SubscriptionId, suscriber_sub_id: Option<SubscriptionId>, message: OutboundMessage ) -> Result<(), StomperError>

Implementors§