Function NewQueueConsumer

shared/messaging/queue_consumer.go:16–22

(rb *RabbitMQ, connMgr *ConnectionManager, queueName string)

}

func NewQueueConsumer(rb *RabbitMQ, connMgr *ConnectionManager, queueName string) *QueueConsumer {
	return &QueueConsumer{
		rb:        rb,
		connMgr:   connMgr,
		queueName: queueName,
	}
}

func (qc *QueueConsumer) Start() error {
	msgs, err := qc.rb.Channel.Consume(