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

Class HttpEndpointAsyncConnector

java.lang.Object

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

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

io.gravitee.gateway.reactive.api.connector.endpoint.async.HttpEndpointAsyncConnector

All Implemented Interfaces:

io.gravitee.common.component.LifecycleComponent<Connector>, Connector, BaseEndpointConnector<HttpExecutionContext>, EndpointConnector, HttpEndpointConnector, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

EndpointAsyncConnector

public abstract class HttpEndpointAsyncConnector
extends io.gravitee.common.service.AbstractService<Connector>
implements HttpEndpointConnector, EndpointConnector

Specialized HttpEndpointConnector for ApiType.MESSAGE

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_FAILURE_CODE
static final String	FAILURE_ENDPOINT_CONFIGURATION_INVALID
static final String	FAILURE_ENDPOINT_CONNECTION_CLOSED
static final String	FAILURE_ENDPOINT_CONNECTION_FAILED
static final String	FAILURE_ENDPOINT_PUBLISH_FAILED
static final String	FAILURE_ENDPOINT_SUBSCRIBE_FAILED
static final String	FAILURE_ENDPOINT_UNKNOWN_ERROR
static final String	FAILURE_PARAMETERS_EXCEPTION

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

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Completable	connect(ExecutionContext ctx)
io.reactivex.rxjava3.core.Completable	connect(HttpExecutionContext ctx)
abstract io.reactivex.rxjava3.core.Completable	publish(HttpExecutionContext ctx)
abstract io.reactivex.rxjava3.core.Completable	subscribe(HttpExecutionContext ctx)
ApiType	supportedApi()	Returns the ApiType supported by this endpoint.
abstract Set<Qos>	supportedQos()	Returns a set of Qos supported by this connector.
abstract Set<QosCapability>	supportedQosCapabilities()	Returns a set of QosCapability supported by this connector.

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.Connector

id, supportedModes

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

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

Field Details

FAILURE_ENDPOINT_CONNECTION_FAILED

public static final String FAILURE_ENDPOINT_CONNECTION_FAILED

See Also:

• Constant Field Values

FAILURE_ENDPOINT_CONNECTION_CLOSED

public static final String FAILURE_ENDPOINT_CONNECTION_CLOSED

See Also:

• Constant Field Values

FAILURE_ENDPOINT_CONFIGURATION_INVALID

public static final String FAILURE_ENDPOINT_CONFIGURATION_INVALID

See Also:

• Constant Field Values

FAILURE_ENDPOINT_UNKNOWN_ERROR

public static final String FAILURE_ENDPOINT_UNKNOWN_ERROR

See Also:

• Constant Field Values

FAILURE_ENDPOINT_PUBLISH_FAILED

public static final String FAILURE_ENDPOINT_PUBLISH_FAILED

See Also:

• Constant Field Values

FAILURE_ENDPOINT_SUBSCRIBE_FAILED

public static final String FAILURE_ENDPOINT_SUBSCRIBE_FAILED

See Also:

• Constant Field Values

FAILURE_PARAMETERS_EXCEPTION

public static final String FAILURE_PARAMETERS_EXCEPTION

See Also:

• Constant Field Values

DEFAULT_FAILURE_CODE

public static final int DEFAULT_FAILURE_CODE

See Also:

• Constant Field Values

Constructor Details

HttpEndpointAsyncConnector

public HttpEndpointAsyncConnector()

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.

supportedQos

public abstract Set<Qos> supportedQos()

Returns a set of Qos supported by this connector.

Returns:

set of Qos supported by this connector.

supportedQosCapabilities

public abstract Set<QosCapability> supportedQosCapabilities()

Returns a set of QosCapability supported by this connector.

Returns:

set of QosCapability supported by this connector.

connect

public io.reactivex.rxjava3.core.Completable connect(ExecutionContext ctx)

Specified by:

connect in interface EndpointConnector

connect

public io.reactivex.rxjava3.core.Completable connect(HttpExecutionContext ctx)

Specified by:

connect in interface BaseEndpointConnector<HttpExecutionContext>

Specified by:

connect in interface EndpointConnector

Specified by:

connect in interface HttpEndpointConnector

subscribe

public abstract io.reactivex.rxjava3.core.Completable subscribe(HttpExecutionContext ctx)

publish

public abstract io.reactivex.rxjava3.core.Completable publish(HttpExecutionContext ctx)