agent/acs/handler/payload_handler.go
func (payloadHandler *payloadRequestHandler) handlerFunc() func(payload *ecsacs.PayloadMessage) {
	// return a function that just enqueues PayloadMessages into the message buffer
	return func(payload *ecsacs.PayloadMessage) {
		payloadHandler.messageBuffer <- payload
	}
}
func (payloadHandler *payloadRequestHandler) handlerFunc() func(payload *ecsacs.PayloadMessage) {
	// return a function that just enqueues PayloadMessages into the message buffer
	return func(payload *ecsacs.PayloadMessage) {
		payloadHandler.messageBuffer <- payload
	}
}
func ( payloadHandler * payloadRequestHandler ) handlerFunc ( ) func ( payload * ecsacs . PayloadMessage ) { // return a function that just enqueues PayloadMessages into the message buffer return func ( payload * ecsacs . PayloadMessage ) { payloadHandler . messageBuffer <- payload } }
// handlerFunc returns the request handler function for the ecsacs.PayloadMessage type
handlerFunc returns the request handler function for the ecsacs . PayloadMessage type