Struct svc_agent::mqtt::IncomingMessageContent

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

Implementations

impl<T, P> IncomingMessageContent<T, P> where
    P: Addressable + Serialize, 

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

pub fn payload(&self) -> &T

pub fn extract_payload(self) -> T

pub fn properties(&self) -> &P

impl<T> IncomingMessageContent<T, IncomingRequestProperties>

pub fn to_response<R>(
    &self,
    data: R,
    status: ResponseStatus,
    timing: OutgoingShortTermTimingProperties,
    api_version: &str
) -> OutgoingMessage<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,
    OutgoingShortTermTimingProperties::until_now(start_timestamp),
);

impl<String: Deref<Target = str>> IncomingMessageContent<T, IncomingEventProperties>

pub fn convert_payload<T>(message: &IncomingEvent<String>) -> Result<T, Error> where
    T: DeserializeOwned, 

pub fn convert<T>(
    message: IncomingEvent<String>
) -> Result<IncomingEvent<T>, Error> where
    T: DeserializeOwned, 

impl<String: Deref<Target = str>> IncomingMessageContent<T, IncomingRequestProperties>

pub fn convert_payload<T>(message: &IncomingRequest<String>) -> Result<T, Error> where
    T: DeserializeOwned, 

pub fn convert<T>(
    message: IncomingRequest<String>
) -> Result<IncomingRequest<T>, Error> where
    T: DeserializeOwned, 

impl<String: Deref<Target = str>> IncomingMessageContent<T, IncomingResponseProperties>

pub fn convert_payload<T>(
    message: &IncomingResponse<String>
) -> Result<T, Error> where
    T: DeserializeOwned, 

pub fn convert<T>(
    message: IncomingResponse<String>
) -> Result<IncomingResponse<T>, Error> where
    T: DeserializeOwned, 

Trait Implementations

impl<T: Clone, P: Clone> Clone for IncomingMessageContent<T, P> where
    P: Addressable + Serialize, 

fn clone(&self) -> IncomingMessageContent<T, P>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug, P: Debug> Debug for IncomingMessageContent<T, P> where
    P: Addressable + Serialize, 

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

Formats the value using the given formatter.