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

Class MessageSnapshot

java.lang.Object

com.predic8.membrane.core.exchange.snapshots.MessageSnapshot

Direct Known Subclasses:

RequestSnapshot, ResponseSnapshot

public class MessageSnapshot
extends Object

Constructor Summary

Constructors

Constructor	Description
MessageSnapshot()
MessageSnapshot(Message msg, ExceptionThrowingConsumer<AbstractExchangeSnapshot> bodyCopiedCallback, AbstractExchangeSnapshot aes, BodyCollectingMessageObserver.Strategy strategy, long limit)

Method Summary

Modifier and Type	Method	Description
AbstractBody	convertBody()
Header	convertHeader()
byte[]	getBody()
Map<String,String>	getHeader()
void	setBody(byte[] body)
void	setHeader(Map<String,String> header)

Methods inherited from class java.lang.Object

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

Constructor Details

MessageSnapshot

public MessageSnapshot(Message msg,
 ExceptionThrowingConsumer<AbstractExchangeSnapshot> bodyCopiedCallback,
 AbstractExchangeSnapshot aes,
 BodyCollectingMessageObserver.Strategy strategy,
 long limit)
                throws IOException

Parameters:

msg - the message to snapshot

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

aes - parameter for the callback

strategy - how to handle body lengths exceeding the limit.

limit - maximum length of the body.

Throws:

IOException

MessageSnapshot

public MessageSnapshot()

Method Details

getHeader

public Map<String,String> getHeader()

setHeader

public void setHeader(Map<String,String> header)

getBody

public byte[] getBody()

setBody

public void setBody(byte[] body)

convertHeader

public Header convertHeader()

convertBody

public AbstractBody convertBody()