reactor/reactor-rabbitmq

Issues

• Add a way to alter the way cancellations are handled

  #184 opened 2 months ago by abelmulq
  0

• Sender does not close / manager resource management channel when declaring objects

  #183 opened 6 months ago by a701440
  3

• Upgrade RabbitMQ client to support Micrometer Observation

  #182 opened 8 months ago by Airidas36
  0

• Reuse channel in receiver to allow setup global qos

  #181 opened 9 months ago by abialas
  0

• Opened channels leaked and mapper return NullPointerException while create new channel for executing rpc request

  #129 opened 4 years ago by kubitre
  7

• Release to repo.spring.io is failing

  #180 opened a year ago by violetagg
  1

• Receiver does not recover or catch the exception when there is a rabbitmq delivery acknowledgement timeout

  #178 opened 2 years ago by yohasakur
  3

• Unclear how to keep the consumer open after an exception is thrown

  #177 opened 2 years ago by jndietz
  0

• receiver.consumeManualAck does not seem compatible with take(int) reactor operator

  #176 opened 2 years ago by chibenwa
  0

• Pulsar and RabbitMQ integration

  #171 opened 2 years ago by lynch19
  3

• RPCs are executed one at a time, blocking on a mutex

  #174 opened 2 years ago by chibenwa
  2

• Provide a way to specify Consumer Arguments in Receiver.consume* methods

  #165 opened 3 years ago by maciejharczuk
  3

• Bump dependencies

  #166 opened 3 years ago by acogoluegnes
  1

• Bump dependencies

  #167 opened 3 years ago by acogoluegnes
  1

• Bump Gradle to 7.2

  #169 opened 3 years ago by acogoluegnes
  0

• AcknowledgableDelivery.ack() blocks

  #164 opened 3 years ago by patrickhuy
  1

• Consider adding an option to Sender.send to reuse the channel

  #163 opened 3 years ago by a701440
  0

• by default reactor rabbit is not setup well for rabbitmq connection loss

  #142 opened 4 years ago by a701440
  8

• Bump dependencies

  #154 opened 3 years ago by acogoluegnes
  1

• Emit publish nack when retry times out

  #156 opened 3 years ago by acogoluegnes
  0

• Emit publish nack when losing connection

  #155 opened 3 years ago by acogoluegnes
  0

• Blocking call when "Sender::sendWithPublisherConfirms"

  #153 opened 3 years ago by 62mkv
  2

• Bump dependencies (1.4.x)

  #151 opened 3 years ago by acogoluegnes
  1

• Switch to Github Actions for CI

  #150 opened 4 years ago by simonbasle
  1

• Not possible to recover receiver after queue deletion

  #149 opened 4 years ago by matejuh
  5

• Bump Reactor to 3.4.0

  #147 opened 4 years ago by acogoluegnes
  1

• Bump Java client to 5.10.0

  #148 opened 4 years ago by acogoluegnes
  1

• Adapt behavior for non-recoverable connections/channels

  #143 opened 4 years ago by acogoluegnes
  9

• Consider making Sender#publish return a flux

  #146 opened 4 years ago by acogoluegnes
  0

• very weird problem (possibly related to SSL connections handling in reactive RabbitMQ client)

  #145 opened 4 years ago by 62mkv
  9

• Bump Reactor

  #144 opened 4 years ago by acogoluegnes
  1

• Provide a "standalone" ack/nack method.

  #139 opened 4 years ago by mxandeco
  7

• Provide channel callback in consume options

  #141 opened 4 years ago by acogoluegnes
  0

• blocking call at Sender#send

  #132 opened 4 years ago by 62mkv
  6

• Any interest in improving consume method's Flux backpressure?

  #126 opened 4 years ago by jspengeman
  1

• Retry when Channel is Closed

  #131 opened 4 years ago by ovu
  5

• Benchmark Test Error

  #140 opened 4 years ago by julang2
  3

• Make Sender#sendWithPublishConfirms use generics

  #112 opened 5 years ago by acogoluegnes
  3

• Bump dependencies

  #136 opened 4 years ago by acogoluegnes
  2

• Expose basicReject when using AcknowledgableDelivery.

  #137 opened 4 years ago by mxandeco
  2

• Shutdown listener added in Sender never get removed and can lead to memory leak when used together with channel pools

  #134 opened 4 years ago by frzme
  1

• Bump dependencies

  #125 opened 4 years ago by acogoluegnes
  1

• add proper SSL support

  #130 opened 4 years ago by 62mkv
  13

• Missing Exchange to Exchange binding API

  #121 opened 5 years ago by cambierr
  7

• Provide an an easy way to supply clientProvidedConnection name

  #120 opened 5 years ago by a701440
  1

• Ensure docsZip defines a -docs classifier

  #119 opened 5 years ago by simonbasle
  1

• Bump Reactor Core

  #118 opened 5 years ago by acogoluegnes
  0

• reactor.rabbitmq.Utils.cache could cause memory leak

  #116 opened 5 years ago by robotmrv
  5

• Add @NonNullApi and @Nullable annotations

  #111 opened 5 years ago by acogoluegnes
  4

• Investigate support for a reactive RPC server

  #114 opened 5 years ago by acogoluegnes
  1