object AmqpFlow
- Source
- AmqpFlow.scala
- Alphabetic
- By Inheritance
- AmqpFlow
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
-
def
create(settings: AmqpWriteSettings): Flow[WriteMessage, WriteResult, CompletionStage[Done]]
Creates an
AmqpFlow
that acceptsWriteMessage
elements and emitsWriteResult
.Creates an
AmqpFlow
that acceptsWriteMessage
elements and emitsWriteResult
.This variant of
AmqpFlow
publishes messages in a fire-and-forget manner, hence all emittedWriteResult
s haveconfirmed
flag set totrue
.This stage materializes to a
CompletionStage
ofDone
, which can be used to know when the Flow completes, either normally or because of an amqp failure.- settings
bufferSize
andconfirmationTimeout
properties are ignored by this connector
-
def
createWithConfirm(settings: AmqpWriteSettings): Flow[WriteMessage, WriteResult, CompletionStage[Done]]
Creates an
AmqpFlow
that acceptsWriteMessage
elements and emitsWriteResult
.Creates an
AmqpFlow
that acceptsWriteMessage
elements and emitsWriteResult
.This variant of
AmqpFlow
asynchronously waits for message confirmations. Maximum number of messages simultaneously waiting for confirmation before signaling backpressure is configured with abufferSize
parameter. Emitted results preserve the order of messages pulled from upstream - due to that restriction this flow is expected to be slightly less effective than it's unordered counterpart.In case of upstream failure/finish this stage attempts to process all buffered messages (waiting for confirmation) before propagating failure/finish downstream.
This stage materializes to a
CompletionStage
ofDone
, which can be used to know when the Flow completes, either normally or because of an amqp failure.NOTE: This connector uses RabbitMQ's extension to AMQP protocol (Publisher Confirms), therefore it is not supposed to be used with another AMQP brokers.
-
def
createWithConfirmAndPassThroughUnordered[T](settings: AmqpWriteSettings): Flow[Pair[WriteMessage, T], Pair[WriteResult, T], CompletionStage[Done]]
Variant of
AmqpFlow.createWithConfirmUnordered
with additional support for pass-through elements.Variant of
AmqpFlow.createWithConfirmUnordered
with additional support for pass-through elements.- See also
AmqpFlow.createWithConfirmUnordered NOTE: This connector uses RabbitMQ's extension to AMQP protocol (Publisher Confirms), therefore it is not supposed to be used with another AMQP brokers.
-
def
createWithConfirmUnordered(settings: AmqpWriteSettings): Flow[WriteMessage, WriteResult, CompletionStage[Done]]
Creates an
AmqpFlow
that acceptsWriteMessage
elements and emitsWriteResult
.Creates an
AmqpFlow
that acceptsWriteMessage
elements and emitsWriteResult
.This variant of
AmqpFlow
asynchronously waits for message confirmations. Maximum number of messages simultaneously waiting for confirmation before signaling backpressure is configured with abufferSize
parameter. Results are emitted downstream as soon as confirmation is received, meaning that there is no ordering guarantee of any sort.In case of upstream failure/finish this stage attempts to process all buffered messages (waiting for confirmation) before propagating failure/finish downstream.
This stage materializes to a
CompletionStage
ofDone
, which can be used to know when the Flow completes, either normally or because of an amqp failure.NOTE: This connector uses RabbitMQ's extension to AMQP protocol (Publisher Confirms), therefore it is not supposed to be used with another AMQP brokers.
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )