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

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CORS_DOMAINS_PROPERTY
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 boolean	corsOrigin(String origin)
protected ProxyRequestHandler	createForNamespace(String namespace)
protected io.fluxzero.sdk.web.WebRequest	createWebRequest(ProxyRequestHandler.JettyExchange exchange, byte[] payload)
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 void	prepareForSending(io.fluxzero.common.api.SerializedMessage responseMessage, ProxyRequestHandler.JettyExchange exchange, int statusCode)
protected void	sendGatewayTimeout(ProxyRequestHandler.JettyExchange exchange)
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)
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

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)

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)

doSendWebRequest

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

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)

close

public void close()

forNamespace

public final ProxyRequestHandler forNamespace(String arg0)

forDefaultNamespace

default ProxyRequestHandler forDefaultNamespace()