Struct epicbox::broker::stomp::subscription_builder::SubscriptionBuilder

pub struct SubscriptionBuilder<'a, T: 'static> {
    pub session: &'a mut Session<T>,
    pub destination: String,
    pub ack_mode: AckMode,
    pub headers: HeaderList,
    pub receipt_request: Option<ReceiptRequest>,
}

Fields

session: &'a mut Session<T>

destination: String

ack_mode: AckMode

headers: HeaderList

receipt_request: Option<ReceiptRequest>

Implementations

impl<'a, T> SubscriptionBuilder<'a, T> where
    T: AsyncWrite + AsyncRead + Send + 'static, 

pub fn new(session: &'a mut Session<T>, destination: String) -> Self

pub fn start(self) -> String

pub fn with<O>(self, option_setter: O) -> SubscriptionBuilder<'a, T> where
    O: OptionSetter<SubscriptionBuilder<'a, T>>, 

Trait Implementations

impl<'a, T> OptionSetter<SubscriptionBuilder<'a, T>> for Header

fn set_option(
    self,
    builder: SubscriptionBuilder<'a, T>
) -> SubscriptionBuilder<'a, T>

impl<'a, T> OptionSetter<SubscriptionBuilder<'a, T>> for AckMode

fn set_option(
    self,
    builder: SubscriptionBuilder<'a, T>
) -> SubscriptionBuilder<'a, T>

impl<'a, T> OptionSetter<SubscriptionBuilder<'a, T>> for GenerateReceipt where
    T: AsyncWrite + AsyncRead + Send + 'static, 

fn set_option(
    self,
    builder: SubscriptionBuilder<'a, T>
) -> SubscriptionBuilder<'a, T>

impl<'a, 'b, T> OptionSetter<SubscriptionBuilder<'b, T>> for SuppressedHeader<'a>

fn set_option(
    self,
    builder: SubscriptionBuilder<'b, T>
) -> SubscriptionBuilder<'b, T>