Commit Graph

Select branches

Hide Pull Requests

develop/feat/more-logs

develop/feat/support-no-action

develop/fix/panic-recover

master

#1

#10

#11

#12

#13

#14

#15

#16

#17

#18

#19

#2

#20

#21

#22

#23

#24

#25

#26

#27

#28

#29

#3

#30

#30

#31

#32

#33

#34

#35

#36

#37

#38

#39

#4

#40

#41

#42

#43

#44

#45

#46

#47

#48

#49

#5

#50

#51

#52

#53

#54

#55

#56

#56

#57

#57

#6

#7

#8

#9

0.9

v.0.0.4

v0.0.1

v0.0.10

v0.0.11

v0.0.2

v0.0.3

v0.0.4

v0.0.5

v0.0.6

v0.0.7

v0.0.8

v0.0.9

Mono Color

• 0b5a8bddbb
  Merge c35190e6b1d93288130699832ffdc6dd3b19fb09 into bdd54501c20f883dc1fb3d61e65908e95cf08e01 Eddy Augusto Santos 2024-06-28 14:09:24 +00:00
• c35190e6b1 (fix): Fix panic recovery in consumer.go develop/fix/panic-recover Eddy Santos 2024-06-27 17:25:06 -03:00
• 734eeaf052
  Merge 0c4f09558972502514060cdd848c64c45902d13b into bdd54501c20f883dc1fb3d61e65908e95cf08e01 Eddy Augusto Santos 2024-04-08 14:55:46 -03:00
• 0c4f095589 (feat): Add topic and data to error log in publish message develop/feat/more-logs Eddy Santos 2024-04-08 10:45:39 -03:00
• dc97af32c1 (feat): Refactor producer to support publishing messages to a queue develop/feat/support-no-action Eddy Santos 2024-04-03 16:43:46 -03:00
• 07caecad0f (feat): Add PublishToQueue method to Producer interface Eddy Santos 2024-04-03 16:43:31 -03:00
• c1a1c35e88 (fix): Add SubscribeWithoutSNS method to consumer Eddy Santos 2024-04-01 14:43:12 -03:00
• 37c706e93b (feat): Refactor logging in consumer.go Eddy Santos 2024-04-01 14:31:52 -03:00
• 30a185120c (feat): Add SubscribeWithoutSNS method to Consumer interface Eddy Santos 2024-04-01 14:15:12 -03:00
• 8f12a56902 (feat): Refactor SNS consumer to support handlers without action Eddy Santos 2024-04-01 14:11:00 -03:00
• bdd54501c2
  Merge pull request #55 from eventials/feat/dual-consumer master Eddy Augusto Santos 2023-06-06 10:15:00 -03:00
• da936f4900 (feat): Implement func to estimate messages queue - Add approximateNumberOfMessages method to the consumer type - This function utilizes AWS SQS's GetQueueAttributes API to fetch an estimated count of the messages currently in the queue Eddy Santos 2023-06-05 15:19:10 -03:00
• 3ea7599c2c (debug): Add debug information for priority check - Added a debug log statement in the checkPriorityMessages function - The debug log outputs when a higher priority consumer has messages in queue, skipping the current consumer Eddy Santos 2023-06-05 13:59:55 -03:00
• f1b607259f (feat): Refactor and improve PriorityConsume function Eddy Santos 2023-06-02 17:03:27 -03:00
• 82c88a052a (feat): implement PriorityConsume function The PriorityConsume function consumes messages based on the priority of consumers. The function registers and logs the handlers of each consumer. It then starts consuming messages in a loop, prioritizing the consumers accordingly. The consumption stops if a stop signal is received from a consumer. The function also checks and handles the scenario when all consumers are stopped. The checkPriorityMessages function is also introduced which determines if a consumer is eligible to consume a message, considering the messages in higher priority consumers. The code has been refactored for improved readability, and detailed comments have been added for better understanding. Eddy Santos 2023-06-02 16:12:26 -03:00
• 68652d356d
  Merge pull request #54 from eventials/add-vendor-folder Breno Alves 2021-10-22 10:15:27 -03:00
• 603c7e60ae chore: add vendor folder Jose Mauro 2021-10-18 14:47:04 -03:00
• 04bec7e32d fix msg timestamp when publish v0.0.11 Guilherme Raduenz 2020-10-21 21:38:41 -03:00
• 978c81a1c1 timestamp from milis v0.0.10 Guilherme Raduenz 2020-10-21 19:41:11 -03:00
• bdc4f9f129
  Merge pull request #53 from skrater/master v0.0.9 0.9 Guilherme Emilio Raduenz 2020-02-29 15:13:17 -03:00
• 9a5a72ba69 max delayed message skrater 2020-02-29 15:09:53 -03:00
• 70c2e9bdba
  Merge pull request #52 from skrater/master v0.0.8 Guilherme Emilio Raduenz 2019-06-24 19:14:21 -03:00
• 764344199d Manual ack nack or reject messages skrater 2019-06-24 18:56:34 -03:00
• f20dc5ff95
  Merge pull request #51 from skrater/fix-producer v0.0.7 Guilherme Emilio Raduenz 2019-05-20 16:54:35 -03:00
• c0b8bd193a Don't log errors in consumer event skrater 2019-05-20 16:45:16 -03:00
• 399e6f3e40
  Merge pull request #50 from skrater/fix-producer v0.0.6 Guilherme Emilio Raduenz 2019-05-20 12:36:26 -03:00
• 245a35bec3 Increased confirms channel length skrater 2019-05-20 12:29:42 -03:00
• f903bc0f7c
  Merge pull request #49 from skrater/master v0.0.5 Guilherme Emilio Raduenz 2019-05-14 12:45:11 -03:00
• 01988e7397 Close channel when publish msg was timed out skrater 2019-05-14 12:39:19 -03:00
• 5187fa6213 customize publish timeout skrater 2019-05-14 12:08:15 -03:00
• f628e92947
  Merge pull request #48 from skrater/master v0.0.4 v.0.0.4 Guilherme Emilio Raduenz 2019-05-01 14:10:16 -03:00
• bf9ff86a03 Remove useless code skrater 2019-05-01 14:08:44 -03:00
• 1e5eeaaa96
  Merge pull request #47 from skrater/master v0.0.3 Guilherme Emilio Raduenz 2019-05-01 13:19:11 -03:00
• 8231c14ac1 Receive notification when channel is closed skrater 2019-05-01 11:38:02 -03:00
• cb1bd81da2
  Merge pull request #46 from skrater/master v0.0.2 Guilherme Emilio Raduenz 2019-03-15 11:35:52 -03:00
• 4d54df7868 Fix producer to no block when publish fail skrater 2019-03-15 11:27:45 -03:00
• cad296e0e3
  Merge pull request #45 from skrater/master v0.0.1 Guilherme Emilio Raduenz 2019-03-12 18:23:29 -03:00
• dce9bd51db Removed continue in producer skrater 2019-03-12 17:30:31 -03:00
• f691357925 Merge branch 'master' of github.com:eventials/goevents skrater 2019-03-12 17:16:32 -03:00
• 2ff4a28210 AMQP: Fixed some data races, and wait producer to dispatch skrater 2019-03-12 16:52:17 -03:00
• db8806183f Don't open channel every publish in producer skrater 2019-03-12 13:32:19 -03:00
• 573d7b9997
  Merge pull request #44 from jaswdr/bypass-acknowledger Guilherme Emilio Raduenz 2018-11-05 14:42:41 -02:00
• dbd0a872ca Add acknowledger events to Event struct Jonathan A. Schweder 2018-11-05 14:34:25 -02:00
• 05a5b865ef Corrected environment variable usage in Dockerfile Jonathan A. Schweder 2018-11-05 14:24:32 -02:00
• 49919dff73
  Merge pull request #42 from skrater/master Guilherme Emilio Raduenz 2018-10-29 14:28:43 -03:00
• 5c35287b6f Remove pointer in Event Context() skrater 2018-10-29 14:22:17 -03:00
• 74b5d89d4e
  Merge pull request #41 from skrater/master Guilherme Emilio Raduenz 2018-08-21 11:38:33 -03:00
• da02ceb2d9 SNS producer skrater 2018-08-21 11:20:56 -03:00
• 41f59da117
  Merge pull request #40 from skrater/master Guilherme Emilio Raduenz 2018-08-16 15:43:02 -03:00
• 22549a8742 SNS QOS skrater 2018-08-16 14:54:29 -03:00
• a06c4a72a1 Handle events async skrater 2018-08-15 18:00:19 -03:00
• 15e7e8fbc3 Fix typo skrater 2018-08-15 17:47:06 -03:00
• 31b724fcc7 Better log messages skrater 2018-08-15 17:42:10 -03:00
• 53cd7ebcd0 Fix tests skrater 2018-08-15 17:19:26 -03:00
• c3add20349 Fix travis build skrater 2018-08-15 17:14:00 -03:00
• 4e8a4889d6 Consume messages from AWS SQS and SNS skrater 2018-08-15 17:00:24 -03:00
• 14d32d7f49
  Merge pull request #39 from jaswdr/master Guilherme Emilio Raduenz 2018-06-15 11:28:10 -03:00
• 35b357f620 Added travis_retry to better handle test run in Travis environment Jonathan A. Schweder 2018-06-15 11:18:10 -03:00
• 1056b6f128
  Merge pull request #38 from jaswdr/master Guilherme Emilio Raduenz 2018-06-15 11:16:46 -03:00
• cbecd945e3 Improved docker files Jonathan A. Schweder 2018-06-15 10:40:03 -03:00
• 9692e82e24
  Merge pull request #37 from skrater/master Guilherme Emilio Raduenz 2018-06-12 14:56:52 -03:00
• c4aa13c9d7 removed Wait methods, due channels leak skrater 2018-06-12 14:48:18 -03:00
• 921713e90e
  Merge pull request #36 from skrater/master Guilherme Emilio Raduenz 2018-05-04 10:16:28 -03:00
• 7d6ef40850 Changed logs to debug skrater 2018-05-04 09:55:55 -03:00
• 4001180607
  Merge pull request #35 from skrater/master Alexandre Vicenzi 2018-05-03 16:41:15 -03:00
• c3fc5bfc9b fix travis tests skrater 2018-05-03 16:22:52 -03:00
• 26439cfd49 methods to bind actions after consume is started skrater 2018-05-03 14:38:57 -03:00
• e0587c53c9
  Merge pull request #34 from alexandrevicenzi/master Alexandre Vicenzi 2018-04-24 15:48:31 -03:00
• a326448807 Add message timestamp. Alexandre Vicenzi 2018-04-24 15:41:26 -03:00
• 948ec3c309
  Merge pull request #33 from skrater/master Guilherme Emilio Raduenz 2018-02-12 10:37:23 -02:00
• f610e9f8be Rebind queue in consume skrater 2018-02-12 10:08:18 -02:00
• 44cb511724 Fix tests skrater 2018-02-12 00:54:10 -02:00
• 46c56e6340 Always setup topology when start consume. skrater 2018-02-11 14:56:48 -02:00
• 1969c2c8f0
  Merge pull request #32 from skrater/master Rafael Mueller 2018-02-11 14:14:28 -02:00
• 885a824119 fix tests skrater 2018-02-10 14:38:29 -02:00
• 37556aaa9c Fix reconnection issue, never reutilize open channels skrater 2018-02-10 13:23:49 -02:00
• c000b21a69
  Merge pull request #31 from rmueller/master Alexandre Vicenzi 2018-01-02 13:38:12 -02:00
• 01ebda1423 Handling error on os.Hostname() Rafael 2018-01-02 12:05:51 -02:00
• 35d8fc9227 Added hostname to the consumer tag Rafael 2018-01-02 11:11:48 -02:00
• 4eb78fa682 Merge 04f10963f06da79e9ee985eb557f756b7b72c60c into 1d8cd4ceb565c0bc8981f761519e95f306501d4c Rafael Mueller 2018-01-02 13:13:47 +00:00
• 04f10963f0 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) Rafael 2018-01-02 11:11:48 -02:00
• 1d8cd4ceb5
  Merge pull request #29 from skrater/master Guilherme Emilio Raduenz 2017-12-21 13:38:54 -02:00
• 5361363689 handle panic on setupTopology and call setupTology if Consume failed skrater 2017-12-21 11:53:44 -02:00
• 27114a294b
  Merge pull request #28 from skrater/master Alexandre Vicenzi 2017-12-19 16:11:47 -02:00
• 844511caca fix log pt2 skrater 2017-12-19 16:05:18 -02:00
• b0b2fe3278 fix log skrater 2017-12-19 16:01:48 -02:00
• 6ef1633e13
  Merge pull request #27 from skrater/master Guilherme Emilio Raduenz 2017-12-19 15:42:25 -02:00
• 81e43b5946 fix mock skrater 2017-12-19 15:37:38 -02:00
• ffc09cba30 fix reconnection skrater 2017-12-19 15:12:30 -02:00
• 154c545800
  Merge pull request #26 from skrater/master Guilherme Emilio Raduenz 2017-12-19 13:09:51 -02:00
• 91c08aca67 fix fmt skrater 2017-12-19 12:15:41 -02:00
• c9d10314ce always generate new queue name skrater 2017-12-19 12:06:26 -02:00
• 06a8443d6f more options to declare queue skrater 2017-12-19 12:02:09 -02:00
• 105925aeda
  Merge pull request #25 from alexandrevicenzi/master Guilherme Emilio Raduenz 2017-10-30 16:56:31 -02:00
• f31bbe2a41 Log event data. Alexandre Vicenzi 2017-10-30 16:51:47 -02:00
• 6db90d5791 Merge pull request #24 from skrater/master Guilherme Emilio Raduenz 2017-10-11 14:51:14 -03:00
• f4de19816d create new channel if consume fail Guilherme 2017-10-11 14:47:15 -03:00
• c442b98446 Merge pull request #23 from skrater/master Guilherme Emilio Raduenz 2017-10-11 10:06:46 -03:00
• 49f155b7f5 fix test Guilherme 2017-10-11 10:03:16 -03:00
• 5c1f2881bf fix test Guilherme 2017-10-11 09:59:56 -03:00