code: func (payloadHandler *payloadRequestHandler) handleMessages() {
  	for {
  		select {
  		case payload := <-payloadHandler.messageBuffer:
  			payloadHandler.handleSingleMessage(payload)
  		case <-payloadHandler.ctx.Done():
  			return
  		}
  	}
  }
docs: // handleMessages processes payload messages in the payload message buffer in-order