Struct message_queue_service::mqs::MessageQueue
[−]
[src]
pub struct MessageQueue;
Methods
impl MessageQueue[src]
fn enqueue_any(body: String)[src]
fn get_all_messages() -> Vec<(String, String)>[src]
Trait Implementations
impl Service for MessageQueue[src]
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 = BoxFuture<Self::Response, Self::Error>
The future response value.
fn call(&self, req: Self::Request) -> Self::Future[src]
Process the request and return the response asynchronously.