code: protected void pushMessage(StatusMessage msg) {
          if (connMsgOut != null) {
              try {
                  connMsgOut.pushMessage(msg);
              } catch (IOException err) {
                  log.error("Error while pushing message: {}", msg, err);
              }
          } else {
              log.warn("Consumer message output is null");
          }
      }
docs: Pushes a message out to a consumer.
  
  @param msg
  StatusMessage