Struct svc_agent::mqtt::OutgoingRequestProperties

pub struct OutgoingRequestProperties { /* private fields */ }

Properties of an outgoing request.

Implementations

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_tracking_label( &mut self, local_tracking_label: String ) -> &mut Self

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

pub fn correlation_data(&self) -> &str

pub fn tags(&self) -> &ExtraTags

pub fn set_tags(&mut self, tags: ExtraTags) -> &mut Self

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.