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 from Project Reactor to express the type of back pressure.

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, using Project Reactor's FluxSink.OverflowStrategy ERROR strategy.
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, using Project Reactor's FluxSink.OverflowStrategy ERROR strategy.

Returns:

initialized backpressure, using Project Reactor's FluxSink.OverflowStrategy ERROR strategy

getOverflowStrategy

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

Gets the overflow strategy.

Returns:

the overflow strategy