Package com.predic8.membrane.core.exchange.snapshots

Class DynamicAbstractExchangeSnapshot

java.lang.Object

com.predic8.membrane.core.exchange.snapshots.AbstractExchangeSnapshot

com.predic8.membrane.core.exchange.snapshots.DynamicAbstractExchangeSnapshot

public class DynamicAbstractExchangeSnapshot
extends AbstractExchangeSnapshot

Constructor Summary

Constructors

Constructor	Description
DynamicAbstractExchangeSnapshot()	called by JSON deserializer
DynamicAbstractExchangeSnapshot(AbstractExchange exc, Interceptor.Flow flow, ExceptionThrowingConsumer<AbstractExchangeSnapshot> bodyCopiedCallback, BodyCollectingMessageObserver.Strategy strategy, long limit)

Method Summary

Modifier and Type	Method	Description
static void	addObservers(AbstractExchange exc, AbstractExchangeSnapshot excCopy, ExceptionThrowingConsumer<AbstractExchangeSnapshot> callback, Interceptor.Flow flow)
static void	update(ExceptionThrowingConsumer<AbstractExchangeSnapshot> callback, AbstractExchangeSnapshot excCopy, AbstractExchange exc, Interceptor.Flow flow)

Methods inherited from class com.predic8.membrane.core.exchange.snapshots.AbstractExchangeSnapshot

getDestinations, getErrorMessage, getId, getOriginalRequestUri, getRemoteAddr, getRemoteAddrIp, getRequest, getResponse, getRule, getServer, getStatus, getTime, getTimeReqReceived, getTimeReqSent, getTimeResReceived, getTimeResSent, setDestinations, setErrorMessage, setId, setOriginalRequestUri, setRemoteAddr, setRemoteAddrIp, setRequest, setResponse, setRule, setServer, setStatus, setTime, setTimeReqReceived, setTimeReqSent, setTimeResReceived, setTimeResSent, toAbstractExchange, updateFrom

Methods inherited from class java.lang.Object

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

Constructor Details

DynamicAbstractExchangeSnapshot

public DynamicAbstractExchangeSnapshot(AbstractExchange exc,
 Interceptor.Flow flow,
 ExceptionThrowingConsumer<AbstractExchangeSnapshot> bodyCopiedCallback,
 BodyCollectingMessageObserver.Strategy strategy,
 long limit)
                                throws IOException

Parameters:

exc - the exchange to snapshot

flow - what to copy from the exchange besides general properties

bodyCopiedCallback - will be called once the flow's body has been filled. if null, the body stream will be read into memory immediately.

strategy - how to handle body lengths exceeding the limit.

limit - maximum length of the body.

Throws:

IOException

DynamicAbstractExchangeSnapshot

public DynamicAbstractExchangeSnapshot()

called by JSON deserializer

Method Details

addObservers

public static void addObservers(AbstractExchange exc,
 AbstractExchangeSnapshot excCopy,
 ExceptionThrowingConsumer<AbstractExchangeSnapshot> callback,
 Interceptor.Flow flow)

update

public static void update(ExceptionThrowingConsumer<AbstractExchangeSnapshot> callback,
 AbstractExchangeSnapshot excCopy,
 AbstractExchange exc,
 Interceptor.Flow flow)