Struct PublisherBuilder 

pub struct PublisherBuilder<P, K, S>
where
    P: Send + Sync + 'static,
{ /* private fields */ }

The builder for a Publisher

Implementations

impl<P> PublisherBuilder<P, NoSelector, NoStorage>

where P: Send + Sync + 'static,

pub fn new(session_id: impl Into<String>, context: Context<P>) -> Self

Construct a PublisherBuilder in initial state

impl<P, K, S> PublisherBuilder<P, K, S>

where P: Send + Sync + 'static,

pub const fn activation_state(self, state: OperationState) -> Self

Set the activation state.

pub fn session_id(self, session_id: &str) -> Self

Set the session id.

pub const fn set_congestion_control( self, congestion_control: CongestionControl, ) -> Self

Set the publishers congestion control

pub fn encoding(self, encoding: String) -> Self

Set the publishers encoding

pub const fn set_express(self, express: bool) -> Self

Set the publishers enexpress policy

pub const fn set_priority(self, priority: Priority) -> Self

Set the publishers priority

impl<P, K> PublisherBuilder<P, K, NoStorage>

where P: Send + Sync + 'static,

pub fn storage( self, storage: Arc<RwLock<HashMap<String, Box<dyn PublisherTrait>>>>, ) -> PublisherBuilder<P, K, Storage<Box<dyn PublisherTrait>>>

Provide agents storage for the publisher

impl<P, S> PublisherBuilder<P, NoSelector, S>

where P: Send + Sync + 'static,

pub fn selector(self, selector: &str) -> PublisherBuilder<P, Selector, S>

Set the full key expression for the Publisher

pub fn topic(self, topic: &str) -> PublisherBuilder<P, Selector, S>

Set only the message qualifing part of the Publisher. Will be prefixed with Agents prefix.

impl<P, S> PublisherBuilder<P, Selector, S>

where P: Send + Sync + 'static,

pub fn build(self) -> Result<Publisher>

Build the Publisher

Errors

Currently none

impl<P> PublisherBuilder<P, Selector, Storage<Box<dyn PublisherTrait>>>

where P: Send + Sync + 'static,

pub fn add(self) -> Result<Option<Box<dyn PublisherTrait>>>

Build and add the Publisher to the Agents context

Errors

Currently none