Packages

o

akka.stream.alpakka.amqp.javadsl

AmqpFlowWithContext

object AmqpFlowWithContext

Source
AmqpFlowWithContext.scala
Linear Supertypes
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 create[T](settings: AmqpWriteSettings): FlowWithContext[WriteMessage, T, WriteResult, T, CompletionStage[Done]]

    Creates a contextual variant of corresponding AmqpFlow.

    Creates a contextual variant of corresponding AmqpFlow.

    See also

    AmqpFlow.create

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

    Creates a contextual variant of corresponding AmqpFlow.

    Creates a contextual variant of corresponding AmqpFlow.

    See also

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