in src/message/messageparser.go [488:515]
func SerializeClientMessageWithAcknowledgeContent(log log.T, acknowledgeContent AcknowledgeContent) (reply []byte, err error) {
acknowledgeContentBytes, err := SerializeClientMessagePayload(log, acknowledgeContent)
if err != nil {
// should not happen
log.Errorf("Cannot marshal acknowledge content to json string: %v", acknowledgeContentBytes)
return
}
uuid.SwitchFormat(uuid.CleanHyphen)
messageId := uuid.NewV4()
clientMessage := ClientMessage{
MessageType: AcknowledgeMessage,
SchemaVersion: 1,
CreatedDate: uint64(time.Now().UnixNano() / 1000000),
SequenceNumber: 0,
Flags: 3,
MessageId: messageId,
Payload: acknowledgeContentBytes,
}
reply, err = clientMessage.SerializeClientMessage(log)
if err != nil {
log.Errorf("Error serializing client message with acknowledge content err: %v", err)
}
return
}