Class ProxyRequestHandler

java.lang.Object

io.fluxzero.proxy.ProxyRequestHandler

public class ProxyRequestHandler
extends Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
protected ProxyRequestHandler	createForNamespace(String namespace)
protected io.fluxzero.sdk.web.WebRequest	createWebRequest(io.undertow.server.HttpServerExchange se, byte[] payload)
protected io.undertow.server.HttpHandler	createWebsocketHandler()
protected void	doSendWebRequest(io.undertow.server.HttpServerExchange se, io.fluxzero.sdk.web.WebRequest webRequest)
default ProxyRequestHandler	forDefaultNamespace()
final ProxyRequestHandler	forNamespace(String arg0)
void	handleRequest(io.undertow.server.HttpServerExchange exchange)
protected void	handleResponse(io.fluxzero.common.api.SerializedMessage responseMessage, io.fluxzero.sdk.web.WebRequest webRequest, io.undertow.server.HttpServerExchange se)
protected io.undertow.server.HttpServerExchange	prepareForSending(io.fluxzero.common.api.SerializedMessage responseMessage, io.undertow.server.HttpServerExchange se, int statusCode)
protected void	sendGatewayTimeout(io.undertow.server.HttpServerExchange se)
protected void	sendResponse(io.fluxzero.common.api.SerializedMessage responseMessage, io.undertow.server.HttpServerExchange se)
protected void	sendServerError(io.undertow.server.HttpServerExchange se)
protected void	sendWebRequest(io.undertow.server.HttpServerExchange se, io.fluxzero.sdk.web.WebRequest webRequest)
protected io.fluxzero.sdk.web.WebRequest	tryUpgrade(io.fluxzero.sdk.web.WebRequest webRequest, io.undertow.server.HttpServerExchange se)

Methods inherited from class Object

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

Constructor Details

ProxyRequestHandler

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

Method Details

createForNamespace

protected ProxyRequestHandler createForNamespace(String namespace)

handleRequest

public void handleRequest(io.undertow.server.HttpServerExchange exchange)

createWebRequest

protected io.fluxzero.sdk.web.WebRequest createWebRequest(io.undertow.server.HttpServerExchange se,
 byte[] payload)

tryUpgrade

protected io.fluxzero.sdk.web.WebRequest tryUpgrade(io.fluxzero.sdk.web.WebRequest webRequest,
 io.undertow.server.HttpServerExchange se)

sendWebRequest

protected void sendWebRequest(io.undertow.server.HttpServerExchange se,
 io.fluxzero.sdk.web.WebRequest webRequest)

doSendWebRequest

protected void doSendWebRequest(io.undertow.server.HttpServerExchange se,
 io.fluxzero.sdk.web.WebRequest webRequest)

handleResponse

protected void handleResponse(io.fluxzero.common.api.SerializedMessage responseMessage,
 io.fluxzero.sdk.web.WebRequest webRequest,
 io.undertow.server.HttpServerExchange se)

prepareForSending

protected io.undertow.server.HttpServerExchange prepareForSending(io.fluxzero.common.api.SerializedMessage responseMessage,
 io.undertow.server.HttpServerExchange se,
 int statusCode)

sendResponse

protected void sendResponse(io.fluxzero.common.api.SerializedMessage responseMessage,
 io.undertow.server.HttpServerExchange se)

sendServerError

protected void sendServerError(io.undertow.server.HttpServerExchange se)

sendGatewayTimeout

protected void sendGatewayTimeout(io.undertow.server.HttpServerExchange se)

close

public void close()

createWebsocketHandler

protected io.undertow.server.HttpHandler createWebsocketHandler()

forNamespace

public final ProxyRequestHandler forNamespace(String arg0)

forDefaultNamespace

default ProxyRequestHandler forDefaultNamespace()