org.axonframework.queryhandling

Class SubscriptionQueryBackpressure

java.lang.Object

org.axonframework.queryhandling.SubscriptionQueryBackpressure

public class SubscriptionQueryBackpressure
extends Object

Backpressure mechanism used for subscription queries. Uses underlying FluxSink.OverflowStrategy to express the type of backpressure.

Since:

3.3

Author:

Milan Savic

Constructor Summary

Constructors

Constructor and Description
SubscriptionQueryBackpressure(reactor.core.publisher.FluxSink.OverflowStrategy overflowStrategy) Initializes backpressure with reactor's overflow strategy.

Method Summary

Modifier and Type	Method and Description
static SubscriptionQueryBackpressure	defaultBackpressure() Creates default backpressure - FluxSink.OverflowStrategy#ERROR.
reactor.core.publisher.FluxSink.OverflowStrategy	getOverflowStrategy() Gets the overflow strategy.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SubscriptionQueryBackpressure

public SubscriptionQueryBackpressure(reactor.core.publisher.FluxSink.OverflowStrategy overflowStrategy)

Initializes backpressure with reactor's overflow strategy.

Parameters:

overflowStrategy - For backpressure handling

Method Detail

defaultBackpressure

public static SubscriptionQueryBackpressure defaultBackpressure()

Creates default backpressure - FluxSink.OverflowStrategy#ERROR.

Returns:

initialized backpressure - FluxSink.OverflowStrategy#ERROR

getOverflowStrategy

public reactor.core.publisher.FluxSink.OverflowStrategy getOverflowStrategy()

Gets the overflow strategy.

Returns:

the overflow strategy