Lane Wagner
|
0958e3a881
|
Merge pull request #191 from taki-mekhalfa/feat/add_queue_message_expiration_option_for_the_consumer
feat: add queue message expiration option for consumer
|
5 months ago |
Lane Wagner
|
a3ac13e165
|
Merge pull request #201 from a-random-lemurian/update-docker-container
fix: Use rabbitmq:4.1.1-alpine in integration test
|
5 months ago |
Lane Wagner
|
3431dc6f85
|
Merge pull request #196 from xBlaz3kx/feature/ping
Feature: Added connection state check
|
5 months ago |
Lemuria
|
c1325d6537
|
fix: Use rabbitmq:4.1.1-alpine in integration test
|
6 months ago |
bdular
|
4bf56e6808
|
Added method that exposes connection state; whether it is closed or not.
|
1 year ago |
Lane Wagner
|
c8749e5cb8
|
Merge pull request #195 from xBlaz3kx/fix/redact-password
Fix: Redact password from URL
|
1 year ago |
bdular
|
c9fe7d9aa0
|
Removed comment
|
1 year ago |
bdular
|
3983b966b2
|
Added function and tests to redact password from URL
|
1 year ago |
Taki
|
9db68050c9
|
feat: add queue message expiration option for consumer
|
1 year ago |
Lane Wagner
|
cd74be0d6e
|
Merge pull request #171 from astromechza/test-contrib
chore: initial integration test
|
1 year ago |
Ben Meier
|
6454487cfe
|
fix: mute until success
|
1 year ago |
Ben Meier
|
2a5cfa7dec
|
chore: update base go version
|
1 year ago |
Ben Meier
|
66ea3dadcf
|
fix: make integration tests more quiet
|
1 year ago |
Ben Meier
|
48b36c16d5
|
chore(ci): added docker based integration test
Signed-off-by: Ben Meier <ben.meier@humanitec.com>
|
1 year ago |
Lane Wagner
|
be104ac5b1
|
Merge pull request #177 from wzy9607/fix/resolver
fix: pass shuffle param to StaticResolver
|
1 year ago |
Lane Wagner
|
e2fda1b586
|
Merge pull request #178 from eric-chao/patch-1
bugfix: graceful consumer shutdown
|
1 year ago |
Xiaojun Zhao
|
a4e904e16c
|
bugfix: graceful consumer shutdown
|
1 year ago |
Cattī Crūdēlēs
|
37ae91ee20
|
fix: pass shuffle param to StaticResolver
|
1 year ago |
Lane Wagner
|
ef6a38050e
|
Merge pull request #170 from astromechza/fix-169
fix: initialise handlerMu in consumer (#169)
|
1 year ago |
Ben Meier
|
a268da1d12
|
fix: initialise handlerMu in consumer (#169)
|
1 year ago |
Lane Wagner
|
8e18cd3f8a
|
Merge pull request #168 from wagslane/lw_rename
Rename mux->mu and update amqp
|
1 year ago |
wagslane
|
5546631dfc
|
don't caer about nil contexts
|
1 year ago |
wagslane
|
e99fa510fb
|
update naming mux -> mu
|
1 year ago |
wagslane
|
786f782071
|
update dep
|
1 year ago |
Lane Wagner
|
7fca926f54
|
Merge pull request #163 from wazsone/feature/cluster
Add cluster support via Resolver
|
1 year ago |
Lane Wagner
|
456bec0d16
|
Merge pull request #166 from thibleroy/main
Consumer: close gracefully
|
1 year ago |
Lane Wagner
|
249fe54719
|
Merge pull request #159 from johanneswuerbach/fix-close-race
fix: consumer close before run
|
1 year ago |
Thibault Leroy
|
0e96881ecd
|
feat(consumer): naming
|
1 year ago |
Thibault Leroy
|
3b40794c2c
|
feat(consumer): log graceful shutdown
|
1 year ago |
Thibault Leroy
|
15bc96b68a
|
feat(consumer): freeupResources
|
2 years ago |
Thibault Leroy
|
2b8632fd72
|
fix(consumer): use ctx in CloseWithContext
|
2 years ago |
Thibault Leroy
|
8929a4e9dc
|
feat(consumer): graceful shutdown
|
2 years ago |
Ruslan Bayandinov
|
5802dd2286
|
Add cluster support via Resolver
Signed-off-by: Ruslan Bayandinov <wazsone@ya.ru>
|
2 years ago |
Lane Wagner
|
eebea887a0
|
Update README.md
|
2 years ago |
Lane Wagner
|
10483c01f1
|
Merge pull request #158 from thepabloaguilar/update-amqp091
update `amqp091-go` from `v1.7.0` to `v1.9.0`
|
2 years ago |
Johannes Würbach
|
e564b431ff
|
fix: consumer close before run
|
2 years ago |
Pablo Aguilar
|
85bdd9e9e7
|
update `amqp091-go` from `v1.7.0` to `v1.9.0`
|
2 years ago |
wagslane
|
325b04909f
|
Merge branch 'main' of https://github.com/wagslane/go-rabbitmq
|
2 years ago |
wagslane
|
6f998163af
|
declare example
|
2 years ago |
Lane Wagner
|
0febae3ab4
|
Merge pull request #154 from wagslane/lw_exchanges
docs and multiple exchanges
|
2 years ago |
wagslane
|
28863cc450
|
docs and multiple exchanges
|
2 years ago |
Lane Wagner
|
90649e4406
|
Merge pull request #145 from ttab/main
Return an error instead of crashing when we cannot retry consumer
|
2 years ago |
Hugo Wetterberg
|
2a1dc36b9a
|
update examples and readme
|
2 years ago |
Hugo Wetterberg
|
d5750cdbc4
|
return an error instead of crashing when we cannot retry
|
2 years ago |
Lane Wagner
|
937bab2745
|
Merge pull request #138 from abbasegbeyemi/remove-tracef-from-logger-interface
Remove tracef from logger interface
|
2 years ago |
Abbas Egbeyemi
|
0957c8a6ce
|
Remove example references
|
2 years ago |
Abbas Egbeyemi
|
b0304e51ec
|
Remove tracef from logger interface
|
2 years ago |
wagslane
|
d6212f3470
|
fix notify publish
|
2 years ago |
Lane Wagner
|
f6f2db89f5
|
Merge pull request #117 from johanneswuerbach/fix-fatal
fix: fatal default log
|
2 years ago |
Lane Wagner
|
328a825282
|
Merge pull request #131 from buni/fix-race-condition-on-msg-confirm
fix ConfirmSafe race condition
|
2 years ago |