code: protected acromusashi.stream.entity.StreamMessage createMessage(String topic, String payload)
      {
          StreamMessageHeader header = new StreamMessageHeader();
          header.setTimestamp(getCurrentTime());
          header.setType("MQTT");
          header.setMessageKey(topic);
  
          acromusashi.stream.entity.StreamMessage message = new acromusashi.stream.entity.StreamMessage(header,
                  payload);
          return message;
      }
docs: AcroMUSASHI用メッセージを生成する。
  
  @param topic Topic
  @param payload Payload
  @return AcroMUSASHI用メッセージ