Package akka.javasdk.consumer

Interface Consumer.Effect.Builder

Enclosing interface:
Consumer.Effect
public static interface Consumer.Effect.Builder
Construct the effect that is returned by the message handler.

  • Method Details

    • done

      Consumer.Effect done()
      Mark message as processed.

    • asyncDone

      Consumer.Effect asyncDone(CompletionStage<akka.Done> message)
      Mark message as processed from an async operation result

    • produce

      <S> Consumer.Effect produce(S message)
      Produce a message.
      Type Parameters:
      S - The type of the message.
      Parameters:
      message - The payload of the message.

    • produce

      <S> Consumer.Effect produce(S message, Metadata metadata)
      Produce a message with custom Metadata.
      Parameters:
      message - The payload of the message.
      metadata - The metadata for the message.

    • asyncProduce

      <S> Consumer.Effect asyncProduce(CompletionStage<S> message)
      Produce a message from an async operation result.
      Parameters:
      message - The future payload of the message.

    • asyncProduce

      <S> Consumer.Effect asyncProduce(CompletionStage<S> message, Metadata metadata)
      Produce a message from an async operation result with custom Metadata.
      Parameters:
      message - The future payload of the message.
      metadata - The metadata for the message.

    • asyncEffect

      Consumer.Effect asyncEffect(CompletionStage<Consumer.Effect> futureEffect)
      Create an async operation result returning an effect.
      Parameters:
      futureEffect - The future effect.

    • ignore

      Consumer.Effect ignore()
      Ignore the current message and proceed with processing the next message