code: @Override
      public boolean onMessage(String channel, IMessage<ID, DATA> msg) {
          counterAll.incrementAndGet();
          counterMap.incrementAndGet(channel);
          return true;
      }
docs: {@inheritDoc}