Packages

object AmqpFlowWithContext

Source
AmqpFlowWithContext.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AmqpFlowWithContext
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def apply[T](settings: AmqpWriteSettings): FlowWithContext[WriteMessage, T, WriteResult, T, Future[Done]]

    Creates a contextual variant of corresponding AmqpFlow.

    Creates a contextual variant of corresponding AmqpFlow.

    See also

    AmqpFlow.apply

  2. def withConfirm[T](settings: AmqpWriteSettings): FlowWithContext[WriteMessage, T, WriteResult, T, Future[Done]]

    Creates a contextual variant of corresponding AmqpFlow.

    Creates a contextual variant of corresponding AmqpFlow.

    See also

    AmqpFlow.withConfirm NOTE: This connector uses RabbitMQ's extension to AMQP protocol (Publisher Confirms), therefore it is not supposed to be used with another AMQP brokers.