Trait svc_agent::mqtt::Publishable

pub trait Publishable {
    fn destination_topic(&self, publisher: &Address) -> Result<String, Error>;
    fn qos(&self) -> QoS;
}

Required methods

fn destination_topic(&self, publisher: &Address) -> Result<String, Error>

Returns a destination topic as string.

Arguments

• publisher – publisher agent.

Example

let topic = message.destination_topic(&agent_id, "v1")?;

fn qos(&self) -> QoS

Returns QoS for publishing.

Loading content...

Implementors

impl<T: Serialize> Publishable for OutgoingEvent<T> where
    OutgoingEvent<T>: IntoEnvelope, 

fn destination_topic(&self, publisher: &Address) -> Result<String, Error>

fn qos(&self) -> QoS

impl<T: Serialize> Publishable for OutgoingRequest<T> where
    OutgoingRequest<T>: IntoEnvelope, 

fn destination_topic(&self, publisher: &Address) -> Result<String, Error>

fn qos(&self) -> QoS

impl<T: Serialize> Publishable for OutgoingResponse<T> where
    OutgoingResponse<T>: IntoEnvelope, 

fn destination_topic(&self, publisher: &Address) -> Result<String, Error>

fn qos(&self) -> QoS

Loading content...