Class ProxyRequestHandler

java.lang.Object

io.fluxzero.proxy.ProxyRequestHandler

public class ProxyRequestHandler
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	ProxyRequestHandler.ChunkAccumulator
protected class	ProxyRequestHandler.ChunkedProxyRequest
protected static class	ProxyRequestHandler.JettyExchange

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CORS_DOMAINS_PROPERTY
static final String	REQUEST_CHUNK_SIZE_PROPERTY	Maximum payload bytes per web request chunk when REQUEST_CHUNKING_ENABLED_PROPERTY is enabled.
static final String	REQUEST_CHUNKING_ENABLED_PROPERTY	Enables publishing large or unknown-length request bodies as chunked web request messages.
static final String	REQUEST_TIMEOUT_SECONDS_PROPERTY

Constructor Summary

Constructors

Constructor	Description
ProxyRequestHandler(io.fluxzero.sdk.configuration.client.Client client)

Method Summary

Modifier and Type	Method	Description
protected boolean	applyCorsHeaders(ProxyRequestHandler.JettyExchange exchange)
void	close()
protected void	completeChunkedResponse(ProxyRequestHandler.ChunkedProxyRequest chunkedRequest, io.fluxzero.common.api.SerializedMessage response, Throwable error, io.fluxzero.sdk.web.WebRequest webRequest, ProxyRequestHandler.JettyExchange exchange)
protected void	completeResponse(io.fluxzero.common.api.SerializedMessage response, Throwable error, io.fluxzero.sdk.web.WebRequest webRequest, ProxyRequestHandler.JettyExchange exchange)
protected boolean	corsOrigin(String origin)
protected io.fluxzero.common.api.SerializedMessage	createChunkedRequestMessage(io.fluxzero.sdk.web.WebRequest webRequest, byte[] chunk, long chunkIndex, boolean firstChunk, boolean finalChunk)
protected ProxyRequestHandler	createForNamespace(String namespace)
protected io.fluxzero.sdk.web.WebRequest	createWebRequest(ProxyRequestHandler.JettyExchange exchange, byte[] payload)
protected ProxyRequestHandler.ChunkedProxyRequest	dispatchReadableChunks(io.fluxzero.sdk.web.WebRequest webRequest, ProxyRequestHandler.ChunkAccumulator pending, boolean last, ProxyRequestHandler.ChunkedProxyRequest chunkedRequest)
protected void	doSendChunkedWebRequest(ProxyRequestHandler.JettyExchange exchange, io.fluxzero.sdk.web.WebRequest webRequest)
protected void	doSendWebRequest(ProxyRequestHandler.JettyExchange exchange, io.fluxzero.sdk.web.WebRequest webRequest)
default ProxyRequestHandler	forDefaultNamespace()
final ProxyRequestHandler	forNamespace(String arg0)
boolean	handle(org.eclipse.jetty.server.Request request, org.eclipse.jetty.server.Response response, org.eclipse.jetty.util.Callback callback)
protected boolean	handleCorsPreflight(ProxyRequestHandler.JettyExchange exchange)
protected void	handleResponse(io.fluxzero.common.api.SerializedMessage responseMessage, io.fluxzero.sdk.web.WebRequest webRequest, ProxyRequestHandler.JettyExchange exchange)
protected boolean	knownRequestBodyTooLarge(ProxyRequestHandler.JettyExchange exchange)
protected void	prepareForSending(io.fluxzero.common.api.SerializedMessage responseMessage, ProxyRequestHandler.JettyExchange exchange, int statusCode)
protected void	readChunkedWebRequest(ProxyRequestHandler.JettyExchange exchange, io.fluxzero.sdk.web.WebRequest webRequest)
protected void	sendGatewayTimeout(ProxyRequestHandler.JettyExchange exchange)
protected void	sendRequestTimeout(ProxyRequestHandler.JettyExchange exchange)
protected void	sendResolvedWebRequest(ProxyRequestHandler.JettyExchange exchange, io.fluxzero.sdk.web.WebRequest webRequest, boolean chunked)
protected void	sendResponse(io.fluxzero.common.api.SerializedMessage responseMessage, ProxyRequestHandler.JettyExchange exchange)
protected void	sendServerError(ProxyRequestHandler.JettyExchange exchange)
protected void	sendWebRequest(ProxyRequestHandler.JettyExchange exchange, io.fluxzero.sdk.web.WebRequest webRequest, boolean chunked)
protected boolean	shouldChunkRequest(ProxyRequestHandler.JettyExchange exchange)
protected io.fluxzero.sdk.web.WebRequest	tryUpgrade(io.fluxzero.sdk.web.WebRequest webRequest)

Methods inherited from class Object

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

Field Details

CORS_DOMAINS_PROPERTY

public static final String CORS_DOMAINS_PROPERTY

See Also:

• Constant Field Values

REQUEST_TIMEOUT_SECONDS_PROPERTY

public static final String REQUEST_TIMEOUT_SECONDS_PROPERTY

See Also:

• Constant Field Values

REQUEST_CHUNKING_ENABLED_PROPERTY

public static final String REQUEST_CHUNKING_ENABLED_PROPERTY

Enables publishing large or unknown-length request bodies as chunked web request messages.

Defaults to false for backward compatibility with applications that still run older SDK clients.

See Also:

• Constant Field Values

REQUEST_CHUNK_SIZE_PROPERTY

public static final String REQUEST_CHUNK_SIZE_PROPERTY

Maximum payload bytes per web request chunk when REQUEST_CHUNKING_ENABLED_PROPERTY is enabled.

See Also:

• Constant Field Values

Constructor Details

ProxyRequestHandler

public ProxyRequestHandler(io.fluxzero.sdk.configuration.client.Client client)

Method Details

createForNamespace

protected ProxyRequestHandler createForNamespace(String namespace)

handle

public boolean handle(org.eclipse.jetty.server.Request request,
 org.eclipse.jetty.server.Response response,
 org.eclipse.jetty.util.Callback callback)

createWebRequest

protected io.fluxzero.sdk.web.WebRequest createWebRequest(ProxyRequestHandler.JettyExchange exchange,
 byte[] payload)

tryUpgrade

protected io.fluxzero.sdk.web.WebRequest tryUpgrade(io.fluxzero.sdk.web.WebRequest webRequest)

knownRequestBodyTooLarge

protected boolean knownRequestBodyTooLarge(ProxyRequestHandler.JettyExchange exchange)

shouldChunkRequest

protected boolean shouldChunkRequest(ProxyRequestHandler.JettyExchange exchange)

handleCorsPreflight

protected boolean handleCorsPreflight(ProxyRequestHandler.JettyExchange exchange)

applyCorsHeaders

protected boolean applyCorsHeaders(ProxyRequestHandler.JettyExchange exchange)

corsOrigin

protected boolean corsOrigin(String origin)

sendWebRequest

protected void sendWebRequest(ProxyRequestHandler.JettyExchange exchange,
 io.fluxzero.sdk.web.WebRequest webRequest,
 boolean chunked)

sendResolvedWebRequest

protected void sendResolvedWebRequest(ProxyRequestHandler.JettyExchange exchange,
 io.fluxzero.sdk.web.WebRequest webRequest,
 boolean chunked)

doSendWebRequest

protected void doSendWebRequest(ProxyRequestHandler.JettyExchange exchange,
 io.fluxzero.sdk.web.WebRequest webRequest)

doSendChunkedWebRequest

protected void doSendChunkedWebRequest(ProxyRequestHandler.JettyExchange exchange,
 io.fluxzero.sdk.web.WebRequest webRequest)

readChunkedWebRequest

protected void readChunkedWebRequest(ProxyRequestHandler.JettyExchange exchange,
 io.fluxzero.sdk.web.WebRequest webRequest)

dispatchReadableChunks

protected ProxyRequestHandler.ChunkedProxyRequest dispatchReadableChunks(io.fluxzero.sdk.web.WebRequest webRequest,
 ProxyRequestHandler.ChunkAccumulator pending,
 boolean last,
 ProxyRequestHandler.ChunkedProxyRequest chunkedRequest)

createChunkedRequestMessage

protected io.fluxzero.common.api.SerializedMessage createChunkedRequestMessage(io.fluxzero.sdk.web.WebRequest webRequest,
 byte[] chunk,
 long chunkIndex,
 boolean firstChunk,
 boolean finalChunk)

completeChunkedResponse

protected void completeChunkedResponse(ProxyRequestHandler.ChunkedProxyRequest chunkedRequest,
 io.fluxzero.common.api.SerializedMessage response,
 Throwable error,
 io.fluxzero.sdk.web.WebRequest webRequest,
 ProxyRequestHandler.JettyExchange exchange)

completeResponse

protected void completeResponse(io.fluxzero.common.api.SerializedMessage response,
 Throwable error,
 io.fluxzero.sdk.web.WebRequest webRequest,
 ProxyRequestHandler.JettyExchange exchange)

handleResponse

protected void handleResponse(io.fluxzero.common.api.SerializedMessage responseMessage,
 io.fluxzero.sdk.web.WebRequest webRequest,
 ProxyRequestHandler.JettyExchange exchange)

prepareForSending

protected void prepareForSending(io.fluxzero.common.api.SerializedMessage responseMessage,
 ProxyRequestHandler.JettyExchange exchange,
 int statusCode)

sendResponse

protected void sendResponse(io.fluxzero.common.api.SerializedMessage responseMessage,
 ProxyRequestHandler.JettyExchange exchange)

sendServerError

protected void sendServerError(ProxyRequestHandler.JettyExchange exchange)

sendGatewayTimeout

protected void sendGatewayTimeout(ProxyRequestHandler.JettyExchange exchange)

sendRequestTimeout

protected void sendRequestTimeout(ProxyRequestHandler.JettyExchange exchange)

close

public void close()

forNamespace

public final ProxyRequestHandler forNamespace(String arg0)

forDefaultNamespace

default ProxyRequestHandler forDefaultNamespace()