code: protected void dispatchMessages(String channel, Message message, Set<IMessageCallback> callbacks) {
          for (IMessageCallback callback : callbacks) {
              try {
                  callback.onMessage(channel, message);
              } catch (Exception e) {
                  
              }
          }
      }
docs: Dispatch message to callback. Override to address special threading considerations.
  
  @param channel The channel that delivered the message.
  @param message The message to dispatch.
  @param callbacks The callbacks to receive the message.