InvalidateLocalCacheMessageListener implements RedisChannelListener { @Override public void onSubscribe() { logger.info("clear local cache"); localCache.clear(); } InvalidateLocalCacheMessageListener(LocalCacheStore localCache); @Override void onSubscribe(); @Override void onMessage(byte[] message);  }
@Test void onSubscribe() { listener.onSubscribe(); verify(cacheStore).clear(); }