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>;
}