Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class MyClass(){
- private Logger logger;
- @Override
- public void prepare(Map map, TopologyContext topologyContext, OutputCollector outputCollector) {
- this.collector = outputCollector;
- logger = LoggerFactory.getLogger(MyClass.class);
- }
- @Override
- public void execute(Tuple tuple) {
- if (TupleHelpers.isTickTuple(tuple)) {
- logger.info("Received tick tuple, triggering emit of current window counts");
- emitCurrentWindowAvgs();
- } else {
- ...
- }
- }
- }
- @RunWith(MockitoJUnitRunner.class)
- public class MyClassTest {
- @Mock
- private Logger logger;
- @InjectMock
- private MyClass myclass;
- @Test
- public void myTest(){
- Tuple tickTuple = MockTupleHelpers.mockTickTuple();
- Myclass myclass = new MyClass();
- // when
- myClass.execute(tickTuple);
- // then
- // verifyZeroInteractions(collector);
- verify(collector).emit(any(Values.class));
- }
- logger = LoggerFactory.getLogger(IntermediateStatisticsBolt.class);
- public MyClass(Logger logger) {
- this.logger = logger;
- }
- @Mock private Logger mockLogger;
- private MyClass myObj; // class under test
- @Before setUp() {
- myObj = new MyClass(mockLogger);
- }
- @InjectMock
- private MyClass myclass
- Myclass myclass = new MyClass();
- public class MyClass(){
- public MyClass() {
- this(LoggerFactory.getLogger(IntermediateStatisticsBolt.class));
- }
- MyClass(Logger logger) { this.logger = logger; }
- logger = LoggerFactory.getLogger(IntermediateStatisticsBolt.class);
- new IntermediateStatisticsBolt(logger); // i.e. a mock or real logger
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement