Trait sawtooth_sdk::messaging::stream::MessageSender

pub trait MessageSender {
    fn send(
        &self, 
        destination: Message_MessageType, 
        correlation_id: &str, 
        contents: &[u8]
    ) -> Result<MessageFuture, SendError>;
    fn reply(
        &self, 
        destination: Message_MessageType, 
        correlation_id: &str, 
        contents: &[u8]
    ) -> Result<(), SendError>;
    fn close(&mut self);
}

A Message Sender

A message

Required methods

fn send(
    &self,
    destination: Message_MessageType,
    correlation_id: &str,
    contents: &[u8]
) -> Result<MessageFuture, SendError>

fn reply(
    &self,
    destination: Message_MessageType,
    correlation_id: &str,
    contents: &[u8]
) -> Result<(), SendError>

fn close(&mut self)

Loading content...

Implementors

impl MessageSender for ZmqMessageSender

fn send(
    &self,
    destination: Message_MessageType,
    correlation_id: &str,
    contents: &[u8]
) -> Result<MessageFuture, SendError>

fn reply(
    &self,
    destination: Message_MessageType,
    correlation_id: &str,
    contents: &[u8]
) -> Result<(), SendError>

fn close(&mut self)

Loading content...