Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
Utility to track messages sent asynchronously, allowing those that are indoubt to be replayed over a new session. More...
#include <qpid/client/MessageReplayTracker.h>
Classes | |
struct | ReplayRecord |
Public Member Functions | |
MessageReplayTracker (uint flushInterval) | |
void | send (const Message &message, const std::string &destination="") |
void | init (AsyncSession session) |
void | replay (AsyncSession session) |
void | setFlushInterval (uint interval) |
uint | getFlushInterval () |
void | checkCompletion () |
template<class F > | |
void | foreach (F &f) |
Utility to track messages sent asynchronously, allowing those that are indoubt to be replayed over a new session.
qpid::client::MessageReplayTracker::MessageReplayTracker | ( | uint | flushInterval | ) |
void qpid::client::MessageReplayTracker::checkCompletion | ( | ) |
void qpid::client::MessageReplayTracker::foreach | ( | F & | f | ) | [inline] |
Definition at line 48 of file MessageReplayTracker.h.
uint qpid::client::MessageReplayTracker::getFlushInterval | ( | ) |
void qpid::client::MessageReplayTracker::init | ( | AsyncSession | session | ) |
void qpid::client::MessageReplayTracker::replay | ( | AsyncSession | session | ) |
void qpid::client::MessageReplayTracker::send | ( | const Message & | message, |
const std::string & | destination = "" |
||
) |
void qpid::client::MessageReplayTracker::setFlushInterval | ( | uint | interval | ) |