Class ProxyRequestHandler

java.lang.Object
io.fluxzero.proxy.ProxyRequestHandler

public class ProxyRequestHandler extends Object
  • Field Details

  • 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)
    • handleCorsPreflight

      protected boolean handleCorsPreflight(io.undertow.server.HttpServerExchange se)
    • applyCorsHeaders

      protected boolean applyCorsHeaders(io.undertow.server.HttpServerExchange se)
    • corsOrigin

      protected boolean corsOrigin(String origin)
    • 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()