org.eclipse.microprofile.reactive.messaging

Annotation Type Acknowledgment

@Retention(value=RUNTIME)
public @interface Acknowledgment

Configure the acknowledgement policy for the given @Incoming. The set of supported acknowledgment policies depends on the method signature. The following list gives the supported strategies for some common use cases. Please refer to the specification for the full list.

• @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): Pre-processing, None, Manual (default)
• @Incoming("in") @Outgoing("out") O method(I payload): Post-Processing (default), Pre-processing, None

Note that all messages must be acknowledged. An absence of acknowledgment is considered as a failure.

Required Element Summary

Required Elements

Modifier and Type	Required Element and Description
Acknowledgment.Strategy	value

Element Detail

value

public abstract Acknowledgment.Strategy value

Returns:

the acknowledgement policy.