Xiaojun Zhao
|
a4e904e16c
|
bugfix: graceful consumer shutdown
|
1 year ago |
Ben Meier
|
a268da1d12
|
fix: initialise handlerMu in consumer (#169)
|
1 year ago |
wagslane
|
5546631dfc
|
don't caer about nil contexts
|
1 year ago |
wagslane
|
e99fa510fb
|
update naming mux -> mu
|
1 year ago |
Thibault Leroy
|
0e96881ecd
|
feat(consumer): naming
|
2 years ago |
Thibault Leroy
|
3b40794c2c
|
feat(consumer): log graceful shutdown
|
2 years 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 |
Johannes Würbach
|
e564b431ff
|
fix: consumer close before run
|
2 years ago |
wagslane
|
28863cc450
|
docs and multiple exchanges
|
2 years ago |
Hugo Wetterberg
|
d5750cdbc4
|
return an error instead of crashing when we cannot retry
|
2 years ago |
wagslane
|
05646d6bbc
|
improve logs
|
3 years ago |
Johannes Würbach
|
dc73f616da
|
recovery from channel failure
|
3 years ago |
Vishal Dubey
|
1b2d3b05a7
|
update: Add manual action to consumer handler
|
3 years ago |
Humberto Navarro
|
63d4c88d28
|
Update consume.go
|
3 years ago |
Aaqa Ishtyaq
|
3589e5a6e5
|
close channel once the consumer is stopped
Signed-off-by: Aaqa Ishtyaq <aaqa@hackerrank.com>
|
3 years ago |
wagslane
|
8a27a8f5b4
|
separate channel for each publisher and consumer
|
3 years ago |
wagslane
|
eea274da92
|
finish options updates for publisher
|
3 years ago |
wagslane
|
0df88ac7e9
|
connection mananger
|
3 years ago |
Christoph Haas
|
62371e8dba
|
queue, exchange and binding declaration is now simplified and much clearer to use
|
3 years ago |
wagslane
|
751df3fe63
|
lowercase f
|
4 years ago |
wagslane
|
9d2ba192df
|
logger
|
4 years ago |
wagslane
|
ea9be35725
|
fixing reconnect issues and updating close API
|
4 years ago |
wagslane
|
dd1fb26231
|
reconnect interval
|
4 years ago |
wagslane
|
6ef45c80f6
|
betting logging for closures
|
4 years ago |
wagslane
|
8eef0b4785
|
small refactor, update amqp
|
4 years ago |
wagslane
|
26cc90b71a
|
fix publishing confirms
|
4 years ago |
wagslane
|
fca30bb394
|
use defaults in consumer
|
4 years ago |
Tom Brouws
|
6f793db5ec
|
feat: add consume options to disable declaring of a queue
Signed-off-by: Tom Brouws <tom@brouws.nl>
|
4 years ago |
Aurelien Perrier
|
67f1a8623a
|
New upstream
rabbitmq/amqp091-go
|
4 years ago |
QiuzZz
|
08e83f54da
|
style
|
4 years ago |
QiuzZz
|
58fd376df4
|
an enum for consumer return value
|
4 years ago |
QiuzZz
|
f27ea86185
|
an enum for consumer return value
|
4 years ago |
Christian Köhn
|
bc434fde5c
|
Add option to skip exchange declaration
|
4 years ago |
Victor Castillo
|
e946a187e5
|
Added the ability to stop the consumers frmo receiving messages, but not from acknolwedging them
|
5 years ago |
Brian Mori
|
f2a2b169a1
|
add connection options and stop publish
|
5 years ago |
wagslane
|
da13fca987
|
refactor
|
5 years ago |
Brian Mori
|
73f54b2d6b
|
adds the consume shutdown
|
5 years ago |
Miguel Bautista
|
ba7b786e63
|
declare exchange before binding
|
5 years ago |
Miguel Bautista
|
3e6f1b7c78
|
declare exchange before binding
|
5 years ago |
Miguel Bautista
|
b23ceb0d79
|
declare exchange before binding
|
5 years ago |
Miguel Bautista
|
04b8c6a9e8
|
declare exchange before binding
|
5 years ago |
lane-c-wagner
|
f4e9141638
|
naming updates
|
5 years ago |
Tommy van Leeuwen
|
fa1267bc6e
|
Replace logger with a Logger interface to allow for custom loggers.
|
5 years ago |
lane-c-wagner
|
7ce11c8fa6
|
examples
|
5 years ago |
lane-c-wagner
|
effbe2c75a
|
add options functions
|
5 years ago |
lane-c-wagner
|
d9535c14ec
|
New not get
|
5 years ago |
lane-c-wagner
|
83cee6f306
|
variadic function options
|
5 years ago |
lane-c-wagner
|
8ac1940b87
|
first
|
5 years ago |