RedisDataBus implements Publisher, DataBus, Closeable { @Override public boolean getHealth() { try (Jedis jedis = redis.getResource()) { return jedis.info() != null; } catch (JedisException je) { logger.error("Redis Health Error : ",je); return false; } } @Inject  RedisDataBus(PropertiesProvider propertiesProvider); @Override int subscribe(Consumer<Message> subscriber, Channel... channels); @Override int subscribe(Consumer<Message> subscriber, Runnable subscriptionCallback, Channel... channels); @Override void unsubscribe(Consumer<Message> subscriber); @Override boolean getHealth(); @Override void publish(Channel channel, Message message); @Override void close();  }
@Test public void test_databus_status(){ assertThat(dataBus.getHealth()).isTrue(); }