public void shouldEmitNothingIfNoObjectHasBeenCountedYetAndTickTupleIsReceived() {
Tuple tickTuple = MockTupleHelpers.mockTickTuple();
RollingCountBolt bolt = new RollingCountBolt();
Map conf = mock(Map.class);
TopologyContext context = mock(TopologyContext.class);
OutputCollector collector = mock(OutputCollector.class);
bolt.prepare(conf, context, collector);
bolt.execute(tickTuple);
verifyZeroInteractions(collector);
}
|