56 Commits (main)

Author SHA1 Message Date
  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 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 4 years ago
  Aurelien Perrier 67f1a8623a
New upstream 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