@Test
public void shouldNotNotifyListenerPredicateNotMatch() throws InterruptedException {

  CountDownLatch latch = new CountDownLatch(1);
  Query query = new Query("select * from table1");
  loggedNode.registerQueryListener(
      (n, l) -> latch.countDown(), false, (l) -> !l.getQuery().equals(query.query));
  Frame request = FrameUtils.wrapRequest(query);
  loggedChannel.writeInbound(request);
  loggedChannel.readInbound();
  assertThat(latch.await(100, TimeUnit.MILLISECONDS)).isFalse();
}