search

adjust / rmq

Message queue system written in Go and backed by Redis
MIT License
1.57k stars 206 forks source link

question? #112

Closed rezaalimorady closed 1 year ago

rezaalimorady commented 2 years ago 
taskConsumer := &TaskConsumer{}
name, err := taskQueue.AddConsumer("task-consumer", taskConsumer)

At your example i give error on &TaskConsumer{}. Couldn't find that

image

wellle commented 2 years ago

So TaskConsumer would be a struct you have to define on your own. And it needs to implement the Consumer interface so that you can use it in the AddConsumer() function. There are some examples of that in this repo.