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.BUFFERstrategy is used with a buffer limited to 128 elements.
-
-
Required Element Summary
Required Elements Modifier and Type Required Element Description OnOverflow.Strategyvalue
-
Optional Element Summary
Optional Elements Modifier and Type Optional Element Description longbufferSize
-
-
-
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.BUFFERis used. If not set and if theOnOverflow.Strategy.BUFFERstrategy is used, the buffer size will be defaulted to the value of the config property mp.messaging.emitter.defult-buffer-size.
- Default:
- 0L
-
-