Struct svc_agent::mqtt::OutgoingRequestProperties

pub struct OutgoingRequestProperties { /* fields omitted */ }

Properties of an outgoing request.

Methods

impl OutgoingRequestProperties

pub fn new(
    method: &str,
    response_topic: &str,
    correlation_data: &str,
    short_term_timing: OutgoingShortTermTimingProperties
) -> Self

Builds OutgoingRequestProperties.

Use this function only if you're making a request from scratch.

If you make a request while handling another request consider using IncomingRequestProperties::to_request.

Arguments

• method – request method.
• response_topic – a topic to send the response to the request to.
• correlation_data – any string to correlate request with the upcoming response.
• short_term_timing – outgoing request's short term timing properties.

Example

let props = OutgoingRequestProperties::new(
    "system.vacuum",
    &Subscription::unicast_responses(),
    OutgoingShortTermTimingProperties::new(Utc::now()),
);

pub fn set_agent_id(&mut self, agent_id: AgentId) -> &mut Self

pub fn set_long_term_timing(
    &mut self,
    timing: LongTermTimingProperties
) -> &mut Self

pub fn set_tracking(&mut self, tracking: TrackingProperties) -> &mut Self

pub fn set_local_timestamp(
    &mut self,
    local_timestamp: DateTime<Utc>
) -> &mut Self

pub fn correlation_data(&self) -> &str

Trait Implementations

impl Debug for OutgoingRequestProperties

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

Formats the value using the given formatter.

impl Serialize for OutgoingRequestProperties

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.