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

Modifier	Constructor	Description
protected	ForwardProxyConsumer(Client client, String consumerName, Long minIndex, boolean mainConsumer, boolean publishMetrics)

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)	Starts managed forwarding with the supplied client and returns a registration for stopping its lifecycle.

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

protected ForwardProxyConsumer(Client client,
 String consumerName,
 Long minIndex,
 boolean mainConsumer,
 boolean publishMetrics)

Method Details

start

public static Registration start(Client client)

Starts managed forwarding with the supplied client and returns a registration for stopping its lifecycle.

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)