Struct svc_agent::mqtt::IncomingMessage

pub struct IncomingMessage<T, P> where
    P: Addressable,  { /* fields omitted */ }

A generic received message.

Methods

impl<T, P> IncomingMessage<T, P> where
    P: Addressable, 

pub fn new(payload: T, properties: P) -> Self

pub fn payload(&self) -> &T

pub fn properties(&self) -> &P

impl<T> IncomingMessage<T, IncomingRequestProperties>

pub fn to_response<R>(
    &self,
    data: R,
    status: ResponseStatus,
    timing: ShortTermTimingProperties,
    api_version: &str
) -> OutgoingResponse<R> where
    R: Serialize, 

Builds OutgoingResponse based on the IncomingRequest.

Use it to response on a request.

Arguments

• data – serializable response payload.
• status – response status.
• timing – outgoing response's short term timing properties.

Example

let response = request.to_response(
    json!({ "foo": "bar" }),
    ResponseStatus::OK,
    ShortTermTimingProperties::until_now(start_timestamp),
);

Trait Implementations

impl<T: Debug, P: Debug> Debug for IncomingMessage<T, P> where
    P: Addressable, 

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

Formats the value using the given formatter.