Struct Processor 

#[non_exhaustive]
pub struct Processor {
    pub name: String,
    pub configuration: Option<ProcessorConfiguration>,
    pub execution_order: i32,
    pub fallback_action: FallbackAction,
}

The information about a processor in a channel flow.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

name: String

The name of the channel flow.

configuration: Option<ProcessorConfiguration>

The information about the type of processor and its identifier.

execution_order: i32

The sequence in which processors run. If you have multiple processors in a channel flow, message processing goes through each processor in the sequence. The value determines the sequence. At this point, we support only 1 processor within a flow.

fallback_action: FallbackAction

Determines whether to continue with message processing or stop it in cases where communication with a processor fails. If a processor has a fallback action of ABORT and communication with it fails, the processor sets the message status to FAILED and does not send the message to any recipients. Note that if the last processor in the channel flow sequence has a fallback action of CONTINUE and communication with the processor fails, then the message is considered processed and sent to recipients of the channel.

Implementations

impl Processor

pub fn name(&self) -> &str

The name of the channel flow.

pub fn configuration(&self) -> Option<&ProcessorConfiguration>

The information about the type of processor and its identifier.

pub fn execution_order(&self) -> i32

The sequence in which processors run. If you have multiple processors in a channel flow, message processing goes through each processor in the sequence. The value determines the sequence. At this point, we support only 1 processor within a flow.

pub fn fallback_action(&self) -> &FallbackAction

Determines whether to continue with message processing or stop it in cases where communication with a processor fails. If a processor has a fallback action of ABORT and communication with it fails, the processor sets the message status to FAILED and does not send the message to any recipients. Note that if the last processor in the channel flow sequence has a fallback action of CONTINUE and communication with the processor fails, then the message is considered processed and sent to recipients of the channel.

impl Processor

pub fn builder() -> ProcessorBuilder

Creates a new builder-style object to manufacture Processor.

Trait Implementations

impl Clone for Processor

fn clone(&self) -> Processor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Processor

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

Formats the value using the given formatter.

impl PartialEq for Processor

fn eq(&self, other: &Processor) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Processor