Interface Processor.Builder

All Superinterfaces:
Buildable, CopyableBuilder<Processor.Builder,Processor>, SdkBuilder<Processor.Builder,Processor>, SdkPojo
Enclosing class:
Processor
@Mutable @NotThreadSafe public static interface Processor.Builder extends SdkPojo, CopyableBuilder<Processor.Builder,Processor>

  • Method Details

    • name

      Processor.Builder name(String name)

      The name of the channel flow.

      Parameters:
      name - The name of the channel flow.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • configuration

      Processor.Builder configuration(ProcessorConfiguration configuration)

      The information about the type of processor and its identifier.

      Parameters:
      configuration - The information about the type of processor and its identifier.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • configuration

      default Processor.Builder configuration(Consumer<ProcessorConfiguration.Builder> configuration)

      The information about the type of processor and its identifier.

      This is a convenience method that creates an instance of the ProcessorConfiguration.Builder avoiding the need to create one manually via ProcessorConfiguration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to configuration(ProcessorConfiguration).

      Parameters:
      configuration - a consumer that will call methods on ProcessorConfiguration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • executionOrder

      Processor.Builder executionOrder(Integer executionOrder)

      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.

      Parameters:
      executionOrder - 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.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • fallbackAction

      Processor.Builder fallbackAction(String 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.

      Parameters:
      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.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • fallbackAction

      Processor.Builder fallbackAction(FallbackAction 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.

      Parameters:
      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.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also: