|
DelegateMQ
|
#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. | |
|
inline |
Constructor.
| transport | The underlying transport to use for re-sending. |
| monitor | The monitor that detects the timeouts. |
| maxRetries | Number of retries before giving up (default 3). |
|
inline |
|
inline |
Sends a message and tracks it for potential retries.