Interface RetryScheduler.Dispatcher<M extends Message,R extends Message>

Type Parameters:
M - The type of Message to dispatch
R - The expected type of Message returned
Enclosing interface:
RetryScheduler

public static interface RetryScheduler.Dispatcher<M extends Message,R extends Message>
Represents the logic to dispatch a message and attempt to retrieve the result
  • Method Details

    • dispatch

      MessageStream<R> dispatch(@Nonnull M message, @Nullable ProcessingContext processingContext)
      Parameters:
      message - The Message to dispatch
      processingContext - The processing context to dispatch the Message under
      Returns:
      a Stream containing the result Messages