Struct SubscriptionOptions 

pub struct SubscriptionOptions {
    pub headers: Vec<(String, String)>,
}

Options to configure a subscription. headers are forwarded to the broker as-is when sending the SUBSCRIBE frame and persisted locally so they can be re-sent on reconnect. This allows broker-specific durable subscription extensions to be used (for example ActiveMQ’s durable subscription headers) while keeping the library generic.

Durability

Durability is requested through headers, using whatever header the broker defines for it - STOMP itself has no durable-subscription concept. For example, ActiveMQ uses activemq.subscriptionName:

let options = SubscriptionOptions {
    headers: vec![(
        "activemq.subscriptionName".to_string(),
        "my-durable-sub".to_string(),
    )],
};

On brokers where a durable queue is declared administratively, such as RabbitMQ, pass that queue as the destination argument; nothing extra is needed here.

Fields

headers: Vec<(String, String)>

Extra headers to include on the SUBSCRIBE frame.

Trait Implementations

impl Clone for SubscriptionOptions

fn clone(&self) -> SubscriptionOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionOptions

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

Formats the value using the given formatter.

impl Default for SubscriptionOptions

fn default() -> SubscriptionOptions

Returns the “default value” for a type.