@Test public void testFail() { SpoutOutputBatcher spout = new SpoutOutputBatcher(this.spoutMock, this.noBatching); Object messageId = mock(Object.class); spout.fail(messageId); verify(this.spoutMock).fail(messageId); }
@Override public void fail(Object msgId) { this.wrappedSpout.fail(msgId); }
SpoutOutputBatcher implements IRichSpout { @Override public void fail(Object msgId) { this.wrappedSpout.fail(msgId); } }
SpoutOutputBatcher implements IRichSpout { @Override public void fail(Object msgId) { this.wrappedSpout.fail(msgId); } SpoutOutputBatcher(IRichSpout spout, int batchSize);  SpoutOutputBatcher(IRichSpout spout, Map<String, Integer> batchSizes); }
SpoutOutputBatcher implements IRichSpout { @Override public void fail(Object msgId) { this.wrappedSpout.fail(msgId); } SpoutOutputBatcher(IRichSpout spout, int batchSize);  SpoutOutputBatcher(IRichSpout spout, Map<String, Integer> batchSizes); @Override void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector); @Override void close(); @Override void activate(); @Override void deactivate(); @Override void nextTuple(); @Override void ack(Object msgId); @Override void fail(Object msgId); @Override void declareOutputFields(OutputFieldsDeclarer declarer); @Override Map<String, Object> getComponentConfiguration(); static void registerKryoClasses(Config stormConfig); }
SpoutOutputBatcher implements IRichSpout { @Override public void fail(Object msgId) { this.wrappedSpout.fail(msgId); } SpoutOutputBatcher(IRichSpout spout, int batchSize);  SpoutOutputBatcher(IRichSpout spout, Map<String, Integer> batchSizes); @Override void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector); @Override void close(); @Override void activate(); @Override void deactivate(); @Override void nextTuple(); @Override void ack(Object msgId); @Override void fail(Object msgId); @Override void declareOutputFields(OutputFieldsDeclarer declarer); @Override Map<String, Object> getComponentConfiguration(); static void registerKryoClasses(Config stormConfig);  }