search

adjust / rmq

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

Is there task aggregating in rmq? #154

Closed lakshy-amagi closed 10 months ago

lakshy-amagi commented 1 year ago

I have implemented rmq for my projects. I need a task aggregator to aggregate tasks for some duration and then publish them to the queue.

wellle commented 1 year ago

Hey, there's no built in aggregation, but you can batch multiple deliveries yourself and then publish them all at once:

queue.Publish(deliveries...)
lakshy-amagi commented 1 year ago

Hey, there's no built in aggregation, but you can batch multiple deliveries yourself and then publish them all at once:

queue.Publish(deliveries...)

Ooh okay will try, Is there any visualizer for rmq workers?

wellle commented 1 year ago

Not sure what exactly you mean, but there's this: https://github.com/adjust/rmq#statistics

wellle commented 10 months ago

Closing as resolved.