adjust / rmq

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

Initial version #1

Closed wellle closed 9 years ago

wellle commented 9 years ago

This PR adds the initial implementation of rmq including some documentation.

NeoHuang commented 9 years ago

shall we clean up the test output a little? if i run go test I'll get following output

2015/08/26 10:55:28 rmq connection connected to push-T2jNOr tcp:localhost:6379 1
2015/08/26 10:55:28 rmq queue started consuming [queue1 conn:push-T2jNOr] 10 1ms
2015/08/26 10:55:28 rmq queue added consumer [queue1 conn:push-T2jNOr] push-cons-Ocbnnb
2015/08/26 10:55:28 rmq queue started consuming [queue2 conn:push-T2jNOr] 10 1ms
2015/08/26 10:55:28 rmq queue added consumer [queue2 conn:push-T2jNOr] push-cons-2O4HcE
2015/08/26 10:55:28 rmq connection connected to queue-conn-NOq4bU tcp:localhost:6379 1
2015/08/26 10:55:28 rmq queue started consuming [queue-q conn:queue-conn-NOq4bU] 10 1ms
2015/08/26 10:55:28 rmq queue added consumer [queue-q conn:queue-conn-NOq4bU] queue-cons1-G3XB8I
2015/08/26 10:55:28 rmq queue added consumer [queue-q conn:queue-conn-NOq4bU] queue-cons2-hHolNC
2015/08/26 10:55:28 rmq queue stopped consuming [queue-q conn:queue-conn-NOq4bU]
2015/08/26 10:55:28 rmq connection connected to return-conn-kolE6R tcp:localhost:6379 1
2015/08/26 10:55:28 rmq queue started consuming [return-q conn:return-conn-kolE6R] 10 1ms
2015/08/26 10:55:28 rmq queue added consumer [return-q conn:return-conn-kolE6R] cons-LoiYVg
...
NeoHuang commented 9 years ago

shall we inject logger instead of using standard log.Printf?

wellle commented 9 years ago

@NeoHuang: Thanks for the feedback. :+1:

I fixed the typo in the Readme and commented out all production logs. We might add a setting for debug logs in the future if there is demand.