75 Commits

Author	SHA1	Message	Date
Guilherme Raduenz	04bec7e32d	fix msg timestamp when publish	2020-10-21 21:38:41 -03:00
Guilherme Raduenz	978c81a1c1	timestamp from milis	2020-10-21 19:41:11 -03:00
skrater	9a5a72ba69	max delayed message	2020-02-29 15:09:53 -03:00
skrater	764344199d	Manual ack nack or reject messages	2019-06-24 18:56:34 -03:00
skrater	c0b8bd193a	Don't log errors in consumer event	2019-05-20 16:45:16 -03:00
skrater	245a35bec3	Increased confirms channel length	2019-05-20 12:29:42 -03:00
skrater	01988e7397	Close channel when publish msg was timed out	2019-05-14 12:39:19 -03:00
skrater	5187fa6213	customize publish timeout	2019-05-14 12:31:43 -03:00
skrater	bf9ff86a03	Remove useless code	2019-05-01 14:09:35 -03:00
skrater	8231c14ac1	Receive notification when channel is closed	2019-05-01 13:09:56 -03:00
skrater	4d54df7868	Fix producer to no block when publish fail	2019-03-15 11:27:45 -03:00
skrater	dce9bd51db	Removed continue in producer	2019-03-12 17:30:31 -03:00
skrater	f691357925	Merge branch 'master' of github.com:eventials/goevents	2019-03-12 17:16:32 -03:00
skrater	2ff4a28210	AMQP: Fixed some data races, and wait producer to dispatch	2019-03-12 17:06:59 -03:00
skrater	db8806183f	Don't open channel every publish in producer	2019-03-12 13:32:19 -03:00
Jonathan A. Schweder	dbd0a872ca	Add acknowledger events to Event struct	2018-11-05 14:34:25 -02:00
skrater	c4aa13c9d7	removed Wait methods, due channels leak	2018-06-12 14:48:18 -03:00
skrater	7d6ef40850	Changed logs to debug	2018-05-04 09:55:55 -03:00
skrater	26439cfd49	methods to bind actions after consume is started	2018-05-03 14:38:57 -03:00
Alexandre Vicenzi	a326448807	Add message timestamp.	2018-04-24 15:41:26 -03:00
skrater	f610e9f8be	Rebind queue in consume	2018-02-12 10:28:13 -02:00
skrater	44cb511724	Fix tests	2018-02-12 00:55:41 -02:00
skrater	46c56e6340	Always setup topology when start consume.	2018-02-11 14:56:48 -02:00
skrater	885a824119	fix tests	2018-02-10 14:38:29 -02:00
skrater	37556aaa9c	Fix reconnection issue, never reutilize open channels	2018-02-10 13:23:49 -02:00
Rafael	01ebda1423	Handling error on os.Hostname() ... As pointed out by @alexandrevicenzi, handling error trying to read os.Hostname()	2018-01-02 12:05:51 -02:00
Rafael	35d8fc9227	Added hostname to the consumer tag ... Added the hostname to the consumerTag at rabbitMQ. Still using the os.args[0] and an unique incremental value as it is used in the default implementation 08577bbc95/consumers.go (L17)	2018-01-02 11:36:55 -02:00
skrater	5361363689	handle panic on setupTopology and call setupTology if Consume failed	2017-12-21 11:53:44 -02:00
skrater	844511caca	fix log pt2	2017-12-19 16:05:18 -02:00
skrater	b0b2fe3278	fix log	2017-12-19 16:01:48 -02:00
Guilherme Emilio Raduenz	6ef1633e13	Merge pull request #27 from skrater/master ... fix reconnection	2017-12-19 15:42:25 -02:00
skrater	ffc09cba30	fix reconnection	2017-12-19 15:28:21 -02:00
Guilherme Emilio Raduenz	154c545800	Merge pull request #26 from skrater/master ... more options to declare queue	2017-12-19 13:09:51 -02:00
skrater	91c08aca67	fix fmt	2017-12-19 12:15:41 -02:00
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
Alexandre Vicenzi	f31bbe2a41	Log event data.	2017-10-30 16:51:47 -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