Package io.gravitee.gateway.reactive.api.connector.entrypoint.async

Class HttpEntrypointAsyncConnector

java.lang.Object

io.gravitee.common.component.AbstractLifecycleComponent<T>

io.gravitee.common.service.AbstractService<Connector>

io.gravitee.gateway.reactive.api.connector.entrypoint.async.HttpEntrypointAsyncConnector

All Implemented Interfaces:

io.gravitee.common.component.LifecycleComponent<Connector>, Connector, BaseEntrypointConnector<HttpExecutionContext>, EntrypointConnector, HttpEntrypointConnector, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

EntrypointAsyncConnector

public abstract class HttpEntrypointAsyncConnector
extends io.gravitee.common.service.AbstractService<Connector>
implements HttpEntrypointConnector, EntrypointConnector

Specialized HttpEntrypointConnector for ApiType.MESSAGE

Field Summary

Fields

Modifier and Type	Field	Description
static final String	STOP_MESSAGE_CONTENT
static final String	STOP_MESSAGE_ID
protected io.reactivex.rxjava3.processors.BehaviorProcessor<Message>	stopHook

Fields inherited from class io.gravitee.common.service.AbstractService

applicationContext

Fields inherited from class io.gravitee.common.component.AbstractLifecycleComponent

lifecycle

Constructor Summary

Constructors

Constructor	Description
HttpEntrypointAsyncConnector()

Method Summary

Modifier and Type	Method	Description
protected io.reactivex.rxjava3.core.FlowableTransformer<Message,Message>	applyStopHook()
void	drainConnections()	Initiates a connection drain process.
void	emitStopMessage()	Emit a stop message to force reconnection.
abstract QosRequirement	qosRequirement()
ApiType	supportedApi()	Returns the ApiType supported by this endpoint.

Methods inherited from class io.gravitee.common.service.AbstractService

doStart, doStop, getOrder, name, setApplicationContext

Methods inherited from class io.gravitee.common.component.AbstractLifecycleComponent

lifecycleState, preStop, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.gravitee.gateway.reactive.api.connector.entrypoint.BaseEntrypointConnector

matchCriteriaCount, supportedListenerType

Methods inherited from interface io.gravitee.gateway.reactive.api.connector.Connector

id, supportedModes

Methods inherited from interface io.gravitee.gateway.reactive.api.connector.entrypoint.EntrypointConnector

handleRequest, handleRequest, handleResponse, handleResponse, matches, matches

Methods inherited from interface io.gravitee.common.component.LifecycleComponent

lifecycleState, postStart, postStop, preStart, preStop, start, stop

Field Details

STOP_MESSAGE_ID

public static final String STOP_MESSAGE_ID

See Also:

• Constant Field Values

STOP_MESSAGE_CONTENT

public static final String STOP_MESSAGE_CONTENT

See Also:

• Constant Field Values

stopHook

protected io.reactivex.rxjava3.processors.BehaviorProcessor<Message> stopHook

Constructor Details

HttpEntrypointAsyncConnector

public HttpEntrypointAsyncConnector()

Method Details

supportedApi

public ApiType supportedApi()

Description copied from interface: Connector

Returns the ApiType supported by this endpoint. It will be used to filter available connector when creating a new API

Specified by:

supportedApi in interface Connector

Returns:

ApiType supported by this connector.

qosRequirement

public abstract QosRequirement qosRequirement()

Returns:

QosRequirement defined by this entrypoint.

drainConnections

public void drainConnections()

Initiates a connection drain process.

Draining connections means gracefully stopping message delivery so that clients are encouraged to close the current connection and reconnect.

This method can be overridden in case the behavior need to be adapted (ex: Webhook).

emitStopMessage

public void emitStopMessage()

Emit a stop message to force reconnection.

applyStopHook

protected io.reactivex.rxjava3.core.FlowableTransformer<Message,Message> applyStopHook()