protected MessageHeaders createHeaders(String sessionId, Long messageId) {
    SimpMessageHeaderAccessor headerAccessor = SimpMessageHeaderAccessor.create(SimpMessageType.MESSAGE);
    headerAccessor.setSessionId(sessionId);
    headerAccessor.setLeaveMutable(true);
    if (messageId != null) {
      headerAccessor.setNativeHeader("messageId", Long.toString(messageId));
    }
    return headerAccessor.getMessageHeaders();
  }
Creates STOMP message header.

@param sessionId
@return message header.
ambari-server/src/main/java/org/apache/ambari/server/events/MessageEmitter.java