agent/acs/handler/payload_handler.go
func (payloadHandler *payloadRequestHandler) ackMessageId(messageID string) {
	seelog.Debugf("Acking payload message id: %s", messageID)
	err := payloadHandler.acsClient.MakeRequest(&ecsacs.AckRequest{
		Cluster:           aws.String(payloadHandler.cluster),
		ContainerInstance: aws.String(payloadHandler.containerInstanceArn),
		MessageId:         aws.String(messageID),
	})
	if err != nil {
		seelog.Warnf("Error 'ack'ing request with messageID: %s, error: %v", messageID, err)
	}
}
func (payloadHandler *payloadRequestHandler) ackMessageId(messageID string) {
	seelog.Debugf("Acking payload message id: %s", messageID)
	err := payloadHandler.acsClient.MakeRequest(&ecsacs.AckRequest{
		Cluster:           aws.String(payloadHandler.cluster),
		ContainerInstance: aws.String(payloadHandler.containerInstanceArn),
		MessageId:         aws.String(messageID),
	})
	if err != nil {
		seelog.Warnf("Error 'ack'ing request with messageID: %s, error: %v", messageID, err)
	}
}
func ( payloadHandler * payloadRequestHandler ) ackMessageId ( messageID string ) { seelog . Debugf ( " " , messageID ) err := payloadHandler . acsClient . MakeRequest ( & ecsacs . AckRequest { Cluster : aws . String ( payloadHandler . cluster ) , ContainerInstance : aws . String ( payloadHandler . containerInstanceArn ) , MessageId : aws . String ( messageID ) , } ) if err != nil { seelog . Warnf ( " " , messageID , err ) } }
// ackMessageId sends an AckRequest for a message id
ackMessageId sends an AckRequest for a message id