Struct wasmcloud_interface_messaging::MessagingSender

pub struct MessagingSender<T: Transport> { /* private fields */ }

MessagingSender sends messages to a Messaging service The Messaging interface describes a service that can deliver messages client for sending Messaging messages

Implementations

impl<T: Transport> MessagingSender<T>

pub fn via(transport: T) -> Self

Constructs a MessagingSender with the specified transport

pub fn set_timeout(&self, interval: Duration)

Trait Implementations

impl<T: Debug + Transport> Debug for MessagingSender<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Transport + Sync + Send> Messaging for MessagingSender<T>

fn publish<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    ctx: &'life1 Context,
    arg: &'life2 PubMessage
) -> Pin<Box<dyn Future<Output = RpcResult<()>> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: 'async_trait,

Publish - send a message The function returns after the message has been sent. If the sender expects to receive an asynchronous reply, the replyTo field should be filled with the subject for the response.

fn request<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 self,
    ctx: &'life1 Context,
    arg: &'life2 RequestMessage
) -> Pin<Box<dyn Future<Output = RpcResult<ReplyMessage>> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: 'async_trait,

Request - send a message in a request/reply pattern, waiting for a response.

fn contract_id() -> &'static str

returns the capability contract id for this interface