Issues
- 8
Allow passive exchange and queue declaration
#84 opened by fridgebuzz - 2
Do we really need queue semantics in the Sender?
#107 opened by gregturn - 3
Enable CorrelationMetadata Emission on SenderMessageResults, Similar to Reactor-Kafka
#109 opened by Sage-Pierce - 0
Bump RabbitMQ Java client
#90 opened by acogoluegnes - 0
Bump Reactor to 3.3
#91 opened by acogoluegnes - 7
Can we have a Receiver example with no Sender?
#106 opened by gregturn - 1
- 22
- 13
- 1
Add hook to configure Mono<Connection>
#105 opened by acogoluegnes - 0
Make Sender and Receiver closing more robust
#103 opened by acogoluegnes - 0
- 0
Make sure RPC client is thread-safe
#81 opened by acogoluegnes - 3
How to Check Connection Health
#101 opened by wtatum - 4
- 3
Using senderOptions.connectionSupplier results in multiple connections created by the Sender
#93 opened by philsttr - 1
Support client-generated consumer tags
#96 opened by philsttr - 9
- 0
- 0
Do not close channel in RpcClient
#92 opened by acogoluegnes - 2
- 0
Bump Reactor to 3.2.8
#83 opened by acogoluegnes - 0
Bump Reactor to 3.2.6
#80 opened by acogoluegnes - 1
Add back pressure for publish confirms
#79 opened by acogoluegnes - 2
Publisher confirms - maxInFlight
#66 opened by pmackowski - 2
- 12
Send failed
#61 opened by viartemev - 2
New isolated thread created ?
#64 opened by smaldini - 3
Receiver Consuming Multiple Queues
#57 opened by mrnewton7 - 3
Example for Spring and Spring Boot
#52 opened by roomanidzee - 0
Bump Java client to 5.6.0
#58 opened by acogoluegnes - 3
Retry automatically on ack/nack failure
#53 opened by pmackowski - 0
Bump Java client to 5.5.3
#55 opened by acogoluegnes - 6
RabbitMQ sender.declareQueue() non exclusive queue but create exclusive queue
#44 opened by trantienduchn - 0
Bump Reactor to 3.2.5
#50 opened by acogoluegnes - 3
Sender - Frame enqueuing failed
#49 opened by pmackowski - 1
Add channel pooling in sender
#48 opened by acogoluegnes - 0
Bump Java client to 5.5.2
#46 opened by acogoluegnes - 1
Don't cache Channel in Sender#send
#43 opened by acogoluegnes - 5
- 2
Please put the RC2 artifact on maven central
#40 opened by mbaechler - 2
- 4
Handle error signal of connectionMono subscription to enable proper error handling
#35 opened by dbuos - 2
Channel is accessible across threads?
#31 opened by lukeknxt - 3
Handle ShutdownSignalException In Receiver
#34 opened by dbuos - 0
Bump Reactor to 3.2.3
#36 opened by acogoluegnes - 0
Bump Reactor to 3.2.2.RELEASE
#33 opened by acogoluegnes - 2
RpcClient Flux replaced with Mono publisher
#32 opened by pmackowski - 1
Bump Reactor to 3.2.1.RELEASE
#30 opened by acogoluegnes - 0
Bump Java client to 5.5.0
#29 opened by acogoluegnes