DelegateMQ
Loading...
Searching...
No Matches
RetryMonitor Class Reference

#include <RetryMonitor.h>

Classes

struct  RetryEntry
 Storage for a message that might need retransmission. More...
 

Public Member Functions

 RetryMonitor (ITransport &transport, TransportMonitor &monitor, int maxRetries=3)
 Constructor.
 
 ~RetryMonitor ()
 
int SendWithRetry (xostringstream &os, const DmqHeader &header)
 Sends a message and tracks it for potential retries.
 

Constructor & Destructor Documentation

◆ RetryMonitor()

RetryMonitor::RetryMonitor ( ITransport & transport,
TransportMonitor & monitor,
int maxRetries = 3 )
inline

Constructor.

Parameters
transportThe underlying transport to use for re-sending.
monitorThe monitor that detects the timeouts.
maxRetriesNumber of retries before giving up (default 3).

◆ ~RetryMonitor()

RetryMonitor::~RetryMonitor ( )
inline

Member Function Documentation

◆ SendWithRetry()

int RetryMonitor::SendWithRetry ( xostringstream & os,
const DmqHeader & header )
inline

Sends a message and tracks it for potential retries.

Returns
0 on success, -1 on immediate transport failure.

The documentation for this class was generated from the following file: