code: @Override
      public boolean onMessage(String channel, IMessage<Long, byte[]> msg) {
          if (msg instanceof UniversalIdIntMessage) {
              return onMessage(channel, (UniversalIdIntMessage) msg);
          }
          throw new IllegalArgumentException("This subscriber expects message of type ["
                  + UniversalIdIntMessage.class.getName() + "]!");
      }
docs: {@inheritDoc}