Struct wascc_actor::msg::DefaultMessageBroker

pub struct DefaultMessageBroker {}

Exposes message broker functionality to actor modules

Methods

impl DefaultMessageBroker

pub fn new() -> Self

Trait Implementations

impl Default for DefaultMessageBroker

fn default() -> Self

Returns the "default value" for a type.

impl MessageBroker for DefaultMessageBroker

fn publish(
    &self,
    subject: &str,
    reply_to: Option<&str>,
    payload: &[u8]
) -> Result<()>

Publishes a new message on the given subject with an optional reply-to

fn request(
    &self,
    subject: &str,
    payload: &[u8],
    timeout_ms: u64
) -> Result<Vec<u8>>

Publishes a message on the given subject and awaits a reply on an inbox subject