@Test
public void executeWithBrokerDown() throws Exception {

    broker.shutdown();
    String message = "value-234";
    Tuple tuple = generateTestTuple(message);
    bolt.execute(tuple);
    verify(collector).fail(tuple);
}