Snippet of GO SQS processor

tasks.go

func (t *Tasks) consumerLoop() {
ConsumerLoop:
	for {
		select {
		case msg := <-t.consumer.MessageChan():
			t.processMessage(msg)

		case <-t.closer.NotifyChan():
			break ConsumerLoop
		}
	}
}

func (t *Tasks) processMessage(msg *sqs.Message) {
	log.Debugf("Process Message: %s", *msg.MessageId)
	msgTypeAttr, ok := msg.MessageAttributes[queue.MsgTypeKey]
	if !ok {
		log.Errorf("Type attribute not found, message ignored")
		t.consumer.Delete(msg)
		return
	}
	msgType := *msgTypeAttr.StringValue
	processor, ok := t.processors[msgType]
	if !ok {
		log.Errorf("Message ignored, invalid task type: %s", msgType)
		t.consumer.Delete(msg)
		return
	}

	processor.Process(msg)
}