diff --git a/wit/messaging.wit b/wit/messaging.wit index cd364c2..a0611d4 100644 --- a/wit/messaging.wit +++ b/wit/messaging.wit @@ -5,7 +5,7 @@ // Note that in this phase 1 interface, subscriptions are defined out of band from this // component. Components themselves cannot establish or terminate subscriptions. This may // change for phase 2. -package wasmcloud:messaging +package wasmcloud:messaging; // Types common to message broker interactions interface types { @@ -18,20 +18,20 @@ interface types { } interface handler { - use types.{broker-message} + use types.{broker-message}; // Callback handled to invoke a function when a message is received from a subscription - handle-message: func(msg: broker-message) -> result<_, string> + handle-message: func(msg: broker-message) -> result<_, string>; } interface consumer { - use types.{broker-message} + use types.{broker-message}; // Perform a request operation on a subject - request: func(subject: string, body: option>, timeout-ms: u32) -> result + request: func(subject: string, body: option>, timeout-ms: u32) -> result; // Performs a request and collects multiple responses. If a non-zero timeout is supplied, this will finish a collection at that time, unless // maximum results is reached first. If both timeout-ms and max-results are 0, the provider will choose when to terminate - request-multi: func(subject: string, body: option>, timeout-ms: u32, max-results: u32) -> result, string> + request-multi: func(subject: string, body: option>, timeout-ms: u32, max-results: u32) -> result, string>; // Publish a message to a subject without awaiting a response - publish: func(msg: broker-message) -> result<_, string> + publish: func(msg: broker-message) -> result<_, string>; }