Class ForwardProxyConsumer

java.lang.Object

io.fluxzero.proxy.ForwardProxyConsumer

All Implemented Interfaces:

Consumer<List<SerializedMessage>>

public class ForwardProxyConsumer
extends Object
implements Consumer<List<SerializedMessage>>

Field Summary

Fields

Modifier and Type	Field	Description
protected static final WebRequestSettings	defaultSettings
protected static final Serializer	metricsSerializer
protected final Map<String, Registration>	runningConsumers
protected static final Serializer	serializer

Constructor Summary

Constructors

Constructor	Description
ForwardProxyConsumer()

Method Summary

Modifier and Type	Method	Description
void	accept(List<SerializedMessage> serializedMessages)
protected HttpRequest	asHttpRequest(SerializedMessage request, URI uri, WebRequestSettings settings)
protected WebResponse	asWebResponse(Throwable e)
protected WebResponse	asWebResponse(HttpResponse<byte[]> response)
protected WebResponse	executeRequest(HttpRequest httpRequest)
protected String	formatType(SerializedMessage request)
protected HttpRequest.BodyPublisher	getBodyPublisher(SerializedMessage request)
protected WebRequestSettings	getSettings(SerializedMessage request)
protected void	handle(SerializedMessage request, URI uri, WebRequestSettings settings)
protected void	publishHandleMessageMetrics(SerializedMessage request, boolean exceptionalResult, Instant start)
protected void	publishProcessBatchMetrics(Instant start)
protected void	sendResponse(WebResponse response, SerializedMessage request)
protected Registration	start()
static Registration	start(Client client)

Methods inherited from class Object

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

Methods inherited from interface Consumer

andThen

Field Details

defaultSettings

protected static final WebRequestSettings defaultSettings

serializer

protected static final Serializer serializer

metricsSerializer

protected static final Serializer metricsSerializer

runningConsumers

protected final Map<String, Registration> runningConsumers

Constructor Details

ForwardProxyConsumer

public ForwardProxyConsumer()

Method Details

start

public static Registration start(Client client)

start

protected Registration start()

accept

public void accept(List<SerializedMessage> serializedMessages)

Specified by:

accept in interface Consumer<List<SerializedMessage>>

handle

protected void handle(SerializedMessage request,
 URI uri,
 WebRequestSettings settings)

asHttpRequest

protected HttpRequest asHttpRequest(SerializedMessage request,
 URI uri,
 WebRequestSettings settings)

getSettings

protected WebRequestSettings getSettings(SerializedMessage request)

executeRequest

protected WebResponse executeRequest(HttpRequest httpRequest)

sendResponse

protected void sendResponse(WebResponse response,
 SerializedMessage request)

asWebResponse

protected WebResponse asWebResponse(HttpResponse<byte[]> response)

asWebResponse

protected WebResponse asWebResponse(Throwable e)

getBodyPublisher

protected HttpRequest.BodyPublisher getBodyPublisher(SerializedMessage request)

publishHandleMessageMetrics

protected void publishHandleMessageMetrics(SerializedMessage request,
 boolean exceptionalResult,
 Instant start)

formatType

protected String formatType(SerializedMessage request)

publishProcessBatchMetrics

protected void publishProcessBatchMetrics(Instant start)