@Incoming("channel")
Subscriber<Message<I>> method()
@Retention(value=RUNTIME) public @interface Acknowledgment
@Incoming
.
Reactive Messaging proposes four acknowledgement strategies:
MANUAL
: the acknowledgement (positive or negative) is up to the user. This is the default strategy
for methods ingesting or producing Message
.
POST_PROCESSING
: acknowledges the incoming message once the produced message is acknowledged.
This is the default strategy for methods ingesting or producing single payloads.PRE_PROCESSING
: acknowledges the incoming messages before calling the method.NONE
: do not apply any acknowledgement. @Incoming("channel") void method(I payload)
: Post-processing (default), Pre-processing, None @Incoming("channel") CompletionStage<?> method(I payload)
: Post-processing (default), Pre-processing, None @Incoming("in") @Outgoing("out") Message<O> method(Message<I> msg)
: , Manual (default), Pre-processing, None @Incoming("in") @Outgoing("out") O method(I payload)
: Post-Processing (default), Pre-processing, NoneSignature | Default Acknowledgement Strategy | Supported Strategies |
---|---|---|
|
Manual |
None, Pre-Processing, Post-Processing (when
the |
|
Post-Processing |
None, Pre-Processing, Post-Processing (when
the |
|
Manual |
None, Pre-Processing, Post-Processing (when
the |
|
Post-Processing |
None, Pre-Processing, Post-Processing (when
the |
|
Post-Processing |
None, Pre-Processing, Post-Processing (when the method returns) |
|
Manual |
None, Pre-Processing, Post-Processing (when
the returned |
|
Post-Processing |
None, Pre-Processing, Post-Processing (when
the returned |
|
Manual |
None, Pre-Processing, Manual |
|
Pre-Processing |
None, Pre-Processing Post-Processing can be optionally supported by implementations, however it requires a 1:1 mapping between the incoming element and the outgoing element. |
|
Manual |
None, Pre-Processing, Manual |
|
Pre-Processing |
None, Pre-Processing Post-Processing can be optionally supported by implementations, however it requires a 1:1 mapping the incoming element and the outgoing element. |
|
Manual |
None, Manual, Pre-Processing |
|
Pre-Processing |
None, Pre-Processing |
|
Manual |
None, Manual, Pre-Processing |
|
Pre-Processing |
None, Pre-Processing |
|
Manual |
None, Manual, Pre-Processing |
|
Post-Processing |
None, Pre-Processing, Post-Processing (when the message wrapping the produced payload is acknowledged) |
|
Manual |
None, Manual, Pre-Processing |
|
Post-Processing |
None, Pre-Processing, Post-Processing (when the message wrapping the produced payload is acknowledged) |
|
Manual |
None, Manual, Pre-Processing |
|
Manual |
None, Manual, Pre-Processing |
|
Pre-Processing |
None, Pre-Processing |
|
Pre-Processing |
None, Pre-Processing |
Modifier and Type | Required Element and Description |
---|---|
Acknowledgment.Strategy |
value |
public abstract Acknowledgment.Strategy value
Copyright © 2018 – 2021 Eclipse Foundation. All rights reserved.
Use is subject to license terms.