io.smallrye.reactive.messaging.annotations

Annotation Type Incomings

@Retention(value=RUNTIME)
 @Target(value=METHOD)
public @interface Incomings

This class is used to allow multiple Incoming declarations. You can either use:

 
 @Incoming("a")
 @Incoming("b")
 public void consume(T t);
 
 

Or use the Incomings annotation as container:

 
 @Incomings({
    @Incoming("a")
    @Incoming("b")
 })
 public void consume(T t);
 

 

NOTE: Experimental, not part of the specification.

Required Element Summary

Required Elements

Modifier and Type	Required Element and Description
Incoming[]	value

Element Detail

value

public abstract Incoming[] value

Returns:

the array of Incoming, must not contain null. All the included Incoming must be value (have a non-blank and non-null channel name).