40 Commits

Author	SHA1	Message	Date
skrater	c9d10314ce	always generate new queue name	2017-12-19 12:06:26 -02:00
skrater	06a8443d6f	more options to declare queue	2017-12-19 12:02:09 -02:00
Guilherme	f4de19816d	create new channel if consume fail	2017-10-11 14:47:15 -03:00
Guilherme	49f155b7f5	fix test	2017-10-11 10:03:16 -03:00
Guilherme	5c1f2881bf	fix test	2017-10-11 09:59:56 -03:00
Guilherme	e87db1c30f	fix test	2017-10-11 09:59:24 -03:00
Guilherme	18a4a1bbd9	fix tests	2017-10-10 19:49:27 -03:00
Guilherme	d1f7a11786	fix retry delay	2017-10-10 19:47:07 -03:00
Guilherme	bd7368b759	fix get retry	2017-10-10 19:22:58 -03:00
Guilherme	030c26dba8	fix delay	2017-10-10 18:55:26 -03:00
Guilherme	bfd7ed11f2	change Consumer struct to private	2017-10-10 18:13:28 -03:00
Guilherme	3d6ee55fa8	not use producer in consumer	2017-10-10 18:06:42 -03:00
Guilherme	ef3afa56c1	attempt to fix retry	2017-10-10 17:49:53 -03:00
Guilherme	4f1add8171	fix consumer waitgroup	2017-10-10 09:54:28 -03:00
Guilherme	65b5375e65	wait for rabbitmq ack	2017-10-09 19:35:34 -03:00
Alexandre Vicenzi	4e9826ca61	Event Id support.	2017-10-09 17:11:02 -03:00
Alexandre Vicenzi	0049262e0a	Use Context as in http.Request.	2017-10-05 17:38:18 -03:00
Alexandre Vicenzi	aa1680aedd	Remove SubscribeWithOptions.	2017-10-05 16:22:28 -03:00
Alexandre Vicenzi	07f407b2dd	Change parameter type.	2017-10-05 15:19:54 -03:00
Alexandre Vicenzi	e04eaa632d	Use struct to pass data.	2017-10-05 14:11:11 -03:00
Alexandre Vicenzi	07fb02bab0	Log handlers.	2017-10-03 17:07:32 -03:00
Guilherme	701e3bda6a	Update logrus organization	2017-07-17 10:14:51 -03:00
Germano Fronza	43613679a8	retry timeout	2017-06-22 16:38:44 -03:00
Alexandre Vicenzi	6ffbcd51a2	Use Prefetch to limit consumer.	2017-06-15 16:29:20 -03:00
Alexandre Vicenzi	5df455293c	Max workers.	2017-06-15 14:08:01 -03:00
Alexandre Vicenzi	343cffc17c	More tests.	2017-06-15 10:05:00 -03:00
Alexandre Vicenzi	4fac8ff6f5	Send message to same queue when retrying.	2017-06-14 18:33:16 -03:00
Alexandre Vicenzi	c801a363b3	Retry feature.	2017-05-26 09:49:38 -03:00
Germano Fronza	200c10ebb2	Fix tests	2017-03-09 23:17:03 -03:00
Germano Fronza	ba58d7e31c	Better log fields to identify the source	2017-03-09 23:03:30 -03:00
Germano Fronza	52625ef13c	Removed retries limit, now retry forever	2017-03-09 22:51:57 -03:00
Germano Fronza	c919262d19	Renamed New functions to the new pattern	2017-03-09 22:24:53 -03:00
Germano Fronza	792e8ef531	Removed wrapped error	2017-03-09 22:22:46 -03:00
Germano Fronza	a5e5fc4ec3	Handling amqp reconnection	2017-03-09 17:32:05 -03:00
Guilherme	0f2bf0cda5	Fix connection error type	2016-12-28 10:20:09 -02:00
Guilherme	7aabd38ab2	Fixes	2016-12-28 09:33:59 -02:00
Guilherme	fcd967b3d4	Refactor to deal connection close	2016-12-28 09:20:29 -02:00
Alexandre Vicenzi	180f26f054	Add Docs.	2016-12-01 16:19:05 -02:00
Alexandre Vicenzi	4709626f35	Add mock package.	2016-12-01 11:40:58 -02:00
Alexandre Vicenzi	144d3870f6	Use interface to allow mocking.	2016-12-01 10:52:22 -02:00