Struct MessageHeaderBuilder

pub struct MessageHeaderBuilder {
    pub ack_kind: MessageAckExpectKind,
    pub subjects: Vec<Subject>,
    /* private fields */
}

Fields

ack_kind: MessageAckExpectKind

subjects: Vec<Subject>

Implementations

impl MessageHeaderBuilder

pub fn new<S: Into<Subject>>(subjects: impl IntoIterator<Item = S>) -> Self

pub fn ack_kind(self, ack_kind: MessageAckExpectKind) -> Self

pub fn mode_online(self) -> Self

pub fn mode_durable(self, config: MessageDurableConfig) -> Self

pub fn mode_pull(self, expire_at: DateTime<Utc>) -> Self

pub fn mode_push(self) -> Self

pub fn build(self) -> MessageHeader