private final Meter _redundantMeter;
private final Meter _discardedMeter;
private final Meter _consolidatedMeter;
private final LoadingCache<SizeCacheKey, Map.Entry<Long, Long>> _eventSizeCache;
private final Supplier<Condition> _defaultJoinFilterCondition;
<BUG>private final Ticker _ticker;
@Inject</BUG>
public DefaultDatabus(LifeCycleRegistry lifeCycle, EventBus eventBus, DataProvider dataProvider,
SubscriptionDAO subscriptionDao, DatabusEventStore eventStore,
SubscriptionEvaluator subscriptionEvaluator, JobService jobService,

private final Meter _redundantMeter;
private final Meter _discardedMeter;
private final Meter _consolidatedMeter;
private final LoadingCache<SizeCacheKey, Map.Entry<Long, Long>> _eventSizeCache;
private final Supplier<Condition> _defaultJoinFilterCondition;
private final Ticker _ticker;
private final Clock _clock;
@Inject
public DefaultDatabus(LifeCycleRegistry lifeCycle, EventBus eventBus, DataProvider dataProvider,
SubscriptionDAO subscriptionDao, DatabusEventStore eventStore,
SubscriptionEvaluator subscriptionEvaluator, JobService jobService,
