Package akka.cluster.ddata

Class PayloadSizeAggregator

java.lang.Object

akka.cluster.ddata.PayloadSizeAggregator

public class PayloadSizeAggregator
extends java.lang.Object

INTERNAL API

This class is not thread-safe. It is supposed to be used from an actor.

Constructor Summary

Constructors

Constructor	Description
PayloadSizeAggregator(LoggingAdapter log, int logSizeExceeding, int maxFrameSize)

Method Summary

Modifier and Type	Method	Description
int	getMaxSize(java.lang.String key)
int	maxFrameSize()
void	remove(java.lang.String key)
void	updatePayloadSize(java.lang.String key, int size)

Methods inherited from class java.lang.Object

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

Constructor Detail

PayloadSizeAggregator

public PayloadSizeAggregator(LoggingAdapter log,
                             int logSizeExceeding,
                             int maxFrameSize)

Method Detail

getMaxSize

public int getMaxSize(java.lang.String key)

maxFrameSize

public int maxFrameSize()

remove

public void remove(java.lang.String key)

updatePayloadSize

public void updatePayloadSize(java.lang.String key,
                              int size)