import { type Transport } from "https://deno.land/x/jok_transport@v0.4.3/mod.ts";
Properties
readonly
state: TransportStateMethods
At this point all handlers are registered and we can
configure Exchange->Queue bindings by calling start()
publish(props: PublishProps<MessageMetadata>): Promise<void>
Publish event, no result will be returned
execute<TResult = unknown>(props: ExecuteProps<MessageMetadata>): Promise<TResult>
Execute RPC call, result will be returned always
throws RPCTimeout error