@Test
void onMessage() throws IOException {

    var message = new InvalidateLocalCacheMessage();
    message.clientIP = "remoteIP";
    message.keys = List.of("key1", "key2");
    listener.onMessage(Strings.bytes(JSON.toJSON(message)));
    verify(cacheStore).delete("key1", "key2");
}