object CommitDelivery

Selects how the stream delivers commits to the internal actor.

Annotations
@ApiMayChange()
Source
CommitterSettings.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CommitDelivery
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. val sendAndForget: CommitDelivery

    Java API.

  2. def valueOf(s: String): CommitDelivery
  3. val waitForAck: CommitDelivery

    Java API.

  4. case object SendAndForget extends CommitDelivery with Product with Serializable

    Send off commits to the internal actor without expecting replies, and don't create backpressure in the stream.

    Send off commits to the internal actor without expecting replies, and don't create backpressure in the stream.

    Annotations
    @ApiMayChange()
  5. case object WaitForAck extends CommitDelivery with Product with Serializable

    Expect replies for commits, and backpressure the stream if replies do not arrive.

    Expect replies for commits, and backpressure the stream if replies do not arrive.

    Annotations
    @ApiMayChange()