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

Class AbstractExchangeSnapshot

java.lang.Object
com.predic8.membrane.core.exchange.snapshots.AbstractExchangeSnapshot
Direct Known Subclasses:
DynamicAbstractExchangeSnapshot
public class AbstractExchangeSnapshot extends Object

  • Constructor Details

    • AbstractExchangeSnapshot

      public AbstractExchangeSnapshot(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

    • AbstractExchangeSnapshot

      public AbstractExchangeSnapshot()
      called by JSON deserializer

  • Method Details

    • updateFrom

      public <T extends AbstractExchangeSnapshot> T updateFrom(AbstractExchange source, Interceptor.Flow flow) throws IOException
      Throws:
      IOException

    • toAbstractExchange

      public AbstractExchange toAbstractExchange()

    • getRequest

      public RequestSnapshot getRequest()

    • setRequest

      public void setRequest(RequestSnapshot request)

    • getResponse

      public ResponseSnapshot getResponse()

    • setResponse

      public void setResponse(ResponseSnapshot response)

    • getId

      public long getId()

    • setId

      public void setId(long id)

    • getOriginalRequestUri

      public String getOriginalRequestUri()

    • setOriginalRequestUri

      public void setOriginalRequestUri(String originalRequestUri)

    • getTime

      public Calendar getTime()

    • setTime

      public void setTime(Calendar time)

    • getErrorMessage

      public String getErrorMessage()

    • setErrorMessage

      public void setErrorMessage(String errorMessage)

    • getStatus

      public ExchangeState getStatus()

    • setStatus

      public void setStatus(ExchangeState status)

    • getTimeReqSent

      public long getTimeReqSent()

    • setTimeReqSent

      public void setTimeReqSent(long timeReqSent)

    • getTimeReqReceived

      public long getTimeReqReceived()

    • setTimeReqReceived

      public void setTimeReqReceived(long timeReqReceived)

    • getTimeResSent

      public long getTimeResSent()

    • setTimeResSent

      public void setTimeResSent(long timeResSent)

    • getTimeResReceived

      public long getTimeResReceived()

    • setTimeResReceived

      public void setTimeResReceived(long timeResReceived)

    • getDestinations

      public List<String> getDestinations()

    • setDestinations

      public void setDestinations(List<String> destinations)

    • getRemoteAddr

      public String getRemoteAddr()

    • setRemoteAddr

      public void setRemoteAddr(String remoteAddr)

    • getRemoteAddrIp

      public String getRemoteAddrIp()

    • setRemoteAddrIp

      public void setRemoteAddrIp(String remoteAddrIp)

    • getRule

      public FakeRule getRule()

    • setRule

      public void setRule(FakeRule rule)

    • getServer

      public String getServer()

    • setServer

      public void setServer(String server)