func SerializeClientMessageWithAcknowledgeContent()

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
}