docs: @Override
      public void onMessage(String channel, Message message) {
          if (MessageUtil.isMessageExcluded(message, RecipientType.CONSUMER, nodeId)) {
              return;
          }
          
          if (updateDelivered(message)) {
              LinkedHashSet<IMessageCallback> callbacks = getCallbacks(channel, false, true);
              
              if (callbacks != null) {
                  dispatchMessages(channel, message, callbacks);
              }
          }
      }