object AmqpFlowWithContext
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- AmqpFlowWithContext
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Value Members
- 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
- 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.