Eddy Augusto Santos
bdd54501c2
Merge pull request #55 from eventials/feat/dual-consumer
...
Feat/dual consumer
2023-06-06 10:15:00 -03:00
Eddy Santos
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
2023-06-05 15:19:10 -03:00
Eddy Santos
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
2023-06-05 13:59:55 -03:00
Eddy Santos
f1b607259f
(feat): Refactor and improve PriorityConsume function
2023-06-02 17:03:27 -03:00
Eddy Santos
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.
2023-06-02 16:12:26 -03:00
Breno Alves
68652d356d
Merge pull request #54 from eventials/add-vendor-folder
...
chore: add vendor folder
2021-10-22 10:15:27 -03:00
Jose Mauro
603c7e60ae
chore: add vendor folder
2021-10-18 14:47:04 -03:00
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
Guilherme Emilio Raduenz
bdc4f9f129
Merge pull request #53 from skrater/master
...
max delayed message
2020-02-29 15:13:17 -03:00
skrater
9a5a72ba69
max delayed message
2020-02-29 15:09:53 -03:00
Guilherme Emilio Raduenz
70c2e9bdba
Merge pull request #52 from skrater/master
...
Manual ack nack or reject messages
2019-06-24 19:14:21 -03:00
skrater
764344199d
Manual ack nack or reject messages
2019-06-24 18:56:34 -03:00
Guilherme Emilio Raduenz
f20dc5ff95
Merge pull request #51 from skrater/fix-producer
...
Don't log errors in consumer event
2019-05-20 16:54:35 -03:00
skrater
c0b8bd193a
Don't log errors in consumer event
2019-05-20 16:45:16 -03:00
Guilherme Emilio Raduenz
399e6f3e40
Merge pull request #50 from skrater/fix-producer
...
Increased confirms channel length
2019-05-20 12:36:26 -03:00
skrater
245a35bec3
Increased confirms channel length
2019-05-20 12:29:42 -03:00
Guilherme Emilio Raduenz
f903bc0f7c
Merge pull request #49 from skrater/master
...
customize publish timeout
2019-05-14 12:45:11 -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
Guilherme Emilio Raduenz
f628e92947
Merge pull request #48 from skrater/master
...
Remove useless code
2019-05-01 14:10:16 -03:00
skrater
bf9ff86a03
Remove useless code
2019-05-01 14:09:35 -03:00
Guilherme Emilio Raduenz
1e5eeaaa96
Merge pull request #47 from skrater/master
...
Receive notification when channel is closed
2019-05-01 13:19:11 -03:00
skrater
8231c14ac1
Receive notification when channel is closed
2019-05-01 13:09:56 -03:00
Guilherme Emilio Raduenz
cb1bd81da2
Merge pull request #46 from skrater/master
...
Fix producer to no block when publish fail
2019-03-15 11:35:52 -03:00
skrater
4d54df7868
Fix producer to no block when publish fail
2019-03-15 11:27:45 -03:00
Guilherme Emilio Raduenz
cad296e0e3
Merge pull request #45 from skrater/master
...
AMQP Fixes
2019-03-12 18:23:29 -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
Guilherme Emilio Raduenz
573d7b9997
Merge pull request #44 from jaswdr/bypass-acknowledger
...
Bypass acknowledger
2018-11-05 14:42:41 -02:00
Jonathan A. Schweder
dbd0a872ca
Add acknowledger events to Event struct
2018-11-05 14:34:25 -02:00
Jonathan A. Schweder
05a5b865ef
Corrected environment variable usage in Dockerfile
2018-11-05 14:24:32 -02:00
Guilherme Emilio Raduenz
49919dff73
Merge pull request #42 from skrater/master
...
Remove pointer in Event Context()
2018-10-29 14:28:43 -03:00
skrater
5c35287b6f
Remove pointer in Event Context()
2018-10-29 14:22:17 -03:00
Guilherme Emilio Raduenz
74b5d89d4e
Merge pull request #41 from skrater/master
...
SNS producer
2018-08-21 11:38:33 -03:00
skrater
da02ceb2d9
SNS producer
2018-08-21 11:26:14 -03:00
Guilherme Emilio Raduenz
41f59da117
Merge pull request #40 from skrater/master
...
Consume messages from AWS SQS and SNS
2018-08-16 15:43:02 -03:00
skrater
22549a8742
SNS QOS
2018-08-16 14:54:29 -03:00
skrater
a06c4a72a1
Handle events async
2018-08-15 18:06:40 -03:00
skrater
15e7e8fbc3
Fix typo
2018-08-15 17:47:06 -03:00
skrater
31b724fcc7
Better log messages
2018-08-15 17:42:10 -03:00
skrater
53cd7ebcd0
Fix tests
2018-08-15 17:19:26 -03:00
skrater
c3add20349
Fix travis build
2018-08-15 17:14:00 -03:00
skrater
4e8a4889d6
Consume messages from AWS SQS and SNS
2018-08-15 17:03:04 -03:00
Guilherme Emilio Raduenz
14d32d7f49
Merge pull request #39 from jaswdr/master
...
Added travis_retry to better handle test running in travis environment
2018-06-15 11:28:10 -03:00
Jonathan A. Schweder
35b357f620
Added travis_retry to better handle test run in Travis environment
2018-06-15 11:18:10 -03:00
Guilherme Emilio Raduenz
1056b6f128
Merge pull request #38 from jaswdr/master
...
Improved docker files
2018-06-15 11:16:46 -03:00
Jonathan A. Schweder
cbecd945e3
Improved docker files
2018-06-15 10:40:03 -03:00
