shared/api/events/consume.go from timoth-y/kicksware-api

shared/api/events/consume.go

35 mins

func (b *Broker) Consume(
    queueName,
    routingKey string,
    handler func(d amqp.Delivery) bool,
    concurrency int) error {

Found in shared/api/events/consume.go - About 35 mins to fix

timoth-y/kicksware-api