org.apache.catalina.tribes.group.interceptors

Class FragmentationInterceptor

public class FragmentationInterceptor extends ChannelInterceptorBase

The fragmentation interceptor splits up large messages into smaller messages and assembles them on the other end. This is very useful when you don't want large messages hogging the sending sockets and smaller messages can make it through.
Configuration Options
OrderInteceptor.expire= - how long do we keep the fragments in memory and wait for the rest to arrivedefault=60,000ms -> 60seconds This setting is useful to avoid OutOfMemoryErrors
OrderInteceptor.maxSize= - message size in bytes default=1024*100 (around a tenth of a MB)

Version: 1.0

Author: Filip Hanik

Nested Class Summary
static class	FragmentationInterceptor.FragCollection
static class	FragmentationInterceptor.FragKey

Field Summary
protected boolean	deepclone
protected HashMap	fragpieces

Method Summary
void	defrag(ChannelMessage msg)
void	frag(Member[] destination, ChannelMessage msg, InterceptorPayload payload)
long	getExpire()
FragmentationInterceptor.FragCollection	getFragCollection(FragmentationInterceptor.FragKey key, ChannelMessage msg)
int	getMaxSize()
void	heartbeat()
void	messageReceived(ChannelMessage msg)
void	removeFragCollection(FragmentationInterceptor.FragKey key)
void	sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload)
void	setExpire(long expire)
void	setMaxSize(int maxSize)

Class FragmentationInterceptor

Field Detail

deepclone

fragpieces

Method Detail

defrag

frag

getExpire

getFragCollection

getMaxSize

heartbeat

messageReceived

removeFragCollection

sendMessage

setExpire

setMaxSize