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.
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.