Upper part of consumer

consumerUpper.go

func (c Consumer) Consume(interruptor *grupttor.Grupttor) q.ConsumeFunc {
	return func(deliveries <-chan amqp.Delivery, done chan error) {
		defer func() {
			if r := recover(); r != nil {
				err := errors.New(fmt.Sprintf("internal goroutine paniced: %v", r))
				log.Error(err)

				// print out the stack
				log.Error(string(debug.Stack()))

				done <- err
			}

			if interruptor.IsInterrupting() {
				// everything ok, just stop
				interruptor.Stop()
			}

			done <- nil //routine done without errors
		}()