issues
search
wagslane
/
go-rabbitmq
A wrapper of streadway/amqp that provides reconnection logic and sane defaults
https://blog.boot.dev/golang/connecting-to-rabbitmq-in-golang-easy/
MIT License
746
stars
125
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
producer connect pool
#179
Mikaelemmmm
opened
4 days ago
1
bugfix: graceful consumer shutdown
#178
eric-chao
opened
6 days ago
0
fix: pass shuffle param to StaticResolver
#177
wzy9607
opened
6 days ago
0
NewStaticResolver's shuffle paramater is not effective
#176
wzy9607
opened
6 days ago
0
fix(shutdown): lock in handlerGoroutine
#175
thibleroy
closed
6 days ago
3
graceful shutdown is invalid
#174
nilnoun
opened
1 week ago
2
consumer: v0.14.0 implementation can lead to unprocessable messages
#173
gnuletik
opened
1 week ago
0
runtime: goroutine stack exceeds 1000000000-byte limit on v0.14.1 after recovery
#172
gnuletik
opened
1 week ago
1
chore: initial integration test
#171
astromechza
opened
1 week ago
0
fix: initialise handlerMu in consumer (#169)
#170
astromechza
closed
1 week ago
2
panic since v0.14.0
#169
gnuletik
closed
1 week ago
2
Rename mux->mu and update amqp
#168
wagslane
closed
2 weeks ago
0
Can consumer support temporary queues?
#167
guodongq
closed
2 weeks ago
1
Consumer: close gracefully
#166
thibleroy
closed
2 weeks ago
1
reconnection err while rabbitmq server handshake_timeout
#165
minhyannv
opened
1 month ago
2
reconnection error: error reconnecting to amqp server: Exception (504) Reason: "channel/connection is not open"
#164
minhyannv
closed
1 month ago
0
Add cluster support via Resolver
#163
wazsone
closed
2 weeks ago
3
reconnection bug
#162
yunxu0604
closed
2 weeks ago
3
NotifyPublish ReconnectCount - how is it intended to be used?
#161
jamoflaw
opened
1 month ago
2
Asynchronous reconnection
#160
timandy
closed
2 weeks ago
3
fix: consumer close before run
#159
johanneswuerbach
closed
2 weeks ago
2
update `amqp091-go` from `v1.7.0` to `v1.9.0`
#158
thepabloaguilar
closed
3 months ago
1
Update: remove logs
#157
nickolajgrishuk
closed
3 months ago
0
Add cluster support via Resolver
#156
nemith
closed
3 months ago
1
Replace `log` to `logger.Logger` in `Dispatcher.Dispatch`
#155
foobarbazmeow
closed
4 months ago
0
docs and multiple exchanges
#154
wagslane
closed
4 months ago
0
Docs specify `WithPublisherOptionsExchangeDeclare` *stops* this library from declaring the exchanges existance
#153
Nikola-Milovic
closed
4 months ago
0
Add support for any kind of declarations when reconnecting
#152
hofmeister
closed
2 months ago
2
how to gracefully shutdown mq consumers?
#151
eric-chao
closed
4 months ago
0
feat: added consumer.WaitForHandlers
#150
astromechza
closed
3 weeks ago
4
memory leak
#149
lmb1113
opened
6 months ago
18
Support for RabbitMQ Clusters
#148
angelokurtis
closed
2 weeks ago
3
add super consumer
#147
qingo
closed
6 months ago
0
A queue can accept multiple bindings from multiple exchanges
#146
qingo
closed
4 months ago
1
Return an error instead of crashing when we cannot retry consumer
#145
hugowetterberg
closed
4 months ago
1
received 'direct' but current is 'topic'"
#144
fighterhit
closed
7 months ago
1
My business requires batch processing of messages. Currently, the Consumer can only provide one callback at a time. Can I open up chan (msgs)? I want to handle message callbacks myself
#143
pzhu1015
closed
4 months ago
1
Declare queue without consuming messages
#142
danikk741
closed
4 months ago
2
Cluster support
#141
ggalihpp-jubelio
closed
8 months ago
1
Support for Dead Letter Exchange
#140
Mokto
closed
4 months ago
1
Shutdown after a fixed number of reconnection attempts
#139
abbasegbeyemi
closed
8 months ago
2
Remove tracef from logger interface
#138
abbasegbeyemi
closed
8 months ago
0
only reconnecting some consumers
#137
MaxBreida
opened
11 months ago
1
rabbitmq-manager no consumers
#136
Mikaelemmmm
closed
11 months ago
2
Direct reply-to
#135
thibleroy
closed
11 months ago
2
Retry Publish Option
#134
gnuletik
closed
8 months ago
5
error on ack
#133
parsibox
closed
1 year ago
1
get message in a variable like github.com/streadway/amqp
#132
parsibox
closed
1 year ago
2
fix ConfirmSafe race condition
#131
buni
closed
1 year ago
1
Race condition when calling PublishWithDeferredConfirmWithContext
#130
buni
closed
1 year ago
1
Next