search

SolaceLabs / solace-quarkus

Solace extension for Quarkus
Apache License 2.0
1 stars 4 forks source link

Handle BackPressure Reject in Outgoing Channel #29

Open SravanThotakura05 opened 9 months ago

SravanThotakura05 commented 9 months ago

Solace Implementation of back-pressure strategy reject uses a callback event which informs about publisher readiness when back-pressure limit for reject is restored to normal state. We need to use this to control the processing of published messages.

In current implementation we are using a SenderProcess class to read the stream of published messages. Publisher readiness should be tied up to this class so that messages are read from stream only when solace publisher is active.

SravanThotakura05 commented 9 months ago

Hi @ozangunalp, added this issue for tracking. As we discussed we need to figure out a way to handle back-pressure reject scenario

ozangunalp commented 9 months ago

Thanks @SravanThotakura05. It summarizes the issue very well.