Package org.axonframework.queryhandling

Class SubscriptionQueryBackpressure

java.lang.Object

org.axonframework.queryhandling.SubscriptionQueryBackpressure

@Deprecated
public class SubscriptionQueryBackpressure
extends Object

Deprecated.

since 3.4.0 Reactor version, Sinks API does not use FluxSink.OverflowStrategy

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	Description
SubscriptionQueryBackpressure(reactor.core.publisher.FluxSink.OverflowStrategy overflowStrategy)	Deprecated. Initializes backpressure with reactor's overflow strategy.

Method Summary

Modifier and Type	Method	Description
static SubscriptionQueryBackpressure	defaultBackpressure()	Deprecated. Creates default backpressure, using Project Reactor's FluxSink.OverflowStrategy ERROR strategy.
reactor.core.publisher.FluxSink.OverflowStrategy	getOverflowStrategy()	Deprecated. Gets the overflow strategy.

Methods inherited from class java.lang.Object

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

Constructor Details

SubscriptionQueryBackpressure

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

Deprecated.

Initializes backpressure with reactor's overflow strategy.

Parameters:

overflowStrategy - For backpressure handling

Method Details

defaultBackpressure

public static SubscriptionQueryBackpressure defaultBackpressure()

Deprecated.

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()

Deprecated.

Gets the overflow strategy.

Returns:

the overflow strategy