Struct CqrsMessagingPolicy 

pub struct CqrsMessagingPolicy<TPayload, TCommand> {
    pub command: CqrsMessageCommandFn<TPayload, TCommand>,
    pub ack_rejected: bool,
    pub outbox_topic: Option<String>,
}

CqrsMessagingPolicy data container.

Fields

command: CqrsMessageCommandFn<TPayload, TCommand>

command field for command.

ack_rejected: bool

ack_rejected field for ack rejected.

outbox_topic: Option<String>

outbox_topic field for outbox topic.

Implementations

impl<TPayload, TCommand> CqrsMessagingPolicy<TPayload, TCommand>

pub fn new( command: impl Fn(&MessageEnvelope<TPayload>, &MessageBusDelivery) -> Option<CqrsCommand<TCommand>> + 'static, ) -> Self

Creates or computes new.

pub fn ack_rejected(self, ack_rejected: bool) -> Self

Updates or reads ack_rejected.

pub fn with_outbox_topic(self, topic: impl Into<String>) -> Self

Updates or reads with_outbox_topic.

Trait Implementations

impl<TPayload: Clone, TCommand: Clone> Clone for CqrsMessagingPolicy<TPayload, TCommand>

fn clone(&self) -> CqrsMessagingPolicy<TPayload, TCommand>

Returns a duplicate of the value.

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

Performs copy-assignment from source.