Trait hedwig::Publisher

pub trait Publisher {
    fn publish<D, T>(
        &self, 
        message: Message<D, T>
    ) -> Result<String, PublishError>
    where
        D: Serialize;
}

A trait for message publishers. This may be used to implement custom behavior such as publish to <insert your favorite cloud platform>.

Required methods

fn publish<D, T>(&self, message: Message<D, T>) -> Result<String, PublishError> where
    D: Serialize, 

Publish a Hedwig message.

Loading content...

Implementors

impl Publisher for GooglePublisher

fn publish<D, T>(&self, message: Message<D, T>) -> Result<String, PublishError> where
    D: Serialize, 

Publishes a message on Google Pubsub and returns a pubsub id (usually an integer).

impl Publisher for MockPublisher

fn publish<D, T>(&self, message: Message<D, T>) -> Result<String, PublishError> where
    D: Serialize, 

Loading content...