_eventStore = eventStore;
_dataProvider = dataProvider;
_subscriptionEvaluator = subscriptionEvaluator;
_jobService = jobService;
_defaultJoinFilterCondition = defaultJoinFilterCondition;
<BUG>_ticker = ticker;
_peekedMeter = newEventMeter("peeked", metricRegistry);</BUG>
_polledMeter = newEventMeter("polled", metricRegistry);
_renewedMeter = newEventMeter("renewed", metricRegistry);
_ackedMeter = newEventMeter("acked", metricRegistry);

_eventStore = eventStore;
_dataProvider = dataProvider;
_subscriptionEvaluator = subscriptionEvaluator;
_jobService = jobService;
_defaultJoinFilterCondition = defaultJoinFilterCondition;
_ticker = ClockTicker.getTicker(clock);
_clock = clock;
_peekedMeter = newEventMeter("peeked", metricRegistry);
_polledMeter = newEventMeter("polled", metricRegistry);
_renewedMeter = newEventMeter("renewed", metricRegistry);
_ackedMeter = newEventMeter("acked", metricRegistry);
