rmq
rmq copied to clipboard
question?
taskConsumer := &TaskConsumer{}
name, err := taskQueue.AddConsumer("task-consumer", taskConsumer)
At your example i give error on &TaskConsumer{}
.
Couldn't find that
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.