@Test
void publishError() {

    when(redis.admin()).thenThrow(new Error("mock"));
    job.execute(null);
    verify(publisher).publish(argThat(message -> "redis".equals(message.app)
            && "ERROR".equals(message.result)
            && "FAILED_TO_COLLECT".equals(message.errorCode)));
}