_discardedMeter = newEventMeter("discarded", metricRegistry);
_consolidatedMeter = newEventMeter("consolidated", metricRegistry);
_eventSizeCache = CacheBuilder.newBuilder()
.expireAfterWrite(15, TimeUnit.SECONDS)
.maximumSize(2000)
<BUG>.ticker(getEventSizeCacheTicker())
.build(new CacheLoader<SizeCacheKey, Map.Entry<Long, Long>>() {</BUG>
@Override
public Map.Entry<Long, Long> load(SizeCacheKey key)
throws Exception {

_discardedMeter = newEventMeter("discarded", metricRegistry);
_consolidatedMeter = newEventMeter("consolidated", metricRegistry);
_eventSizeCache = CacheBuilder.newBuilder()
.expireAfterWrite(15, TimeUnit.SECONDS)
.maximumSize(2000)
.ticker(_ticker)
.build(new CacheLoader<SizeCacheKey, Map.Entry<Long, Long>>() {
@Override
public Map.Entry<Long, Long> load(SizeCacheKey key)
throws Exception {
