Struct MessageQueue

pub struct MessageQueue;

Implementations

impl MessageQueue

pub fn enqueue_any(body: String)

pub fn get_all_messages() -> Vec<(String, String)>

Trait Implementations

impl Service for MessageQueue

type Request = String

Requests handled by the service.

type Response = String

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Box<dyn Future<Item = <MessageQueue as Service>::Response, Error = <MessageQueue as Service>::Error> + Send>

The future response value.

fn call(&self, req: Self::Request) -> Self::Future

Process the request and return the response asynchronously.