Annotation Type OnOverflow
-
@Retention(RUNTIME) @Target({METHOD,CONSTRUCTOR,FIELD,PARAMETER}) public @interface OnOverflow
Configures the back pressure policy on an injectedEmitter
:{ @code @Channel("channel") @OnOverflow(value = OnOverflow.Strategy.BUFFER, bufferSize = 256) Emitter<String> emitter; }
When not used, a
OnOverflow.Strategy.BUFFER
strategy is used with a buffer limited to 128 elements.
-
-
Required Element Summary
Required Elements Modifier and Type Required Element Description OnOverflow.Strategy
value
-
Optional Element Summary
Optional Elements Modifier and Type Optional Element Description long
bufferSize
-
-
-
Element Detail
-
value
OnOverflow.Strategy value
- Returns:
- the name of the strategy to be used on overflow.
-
-
-
bufferSize
long bufferSize
- Returns:
- the size of the buffer when
OnOverflow.Strategy.BUFFER
is used. If not set and if theOnOverflow.Strategy.BUFFER
strategy is used, the buffer size will be defaulted to the value of the config property mp.messaging.emitter.defult-buffer-size.
- Default:
- 0L
-
-