1 #ifndef QPID_CLIENT_MESSAGEREPLAYTRACKER_H
2 #define QPID_CLIENT_MESSAGEREPLAYTRACKER_H
48 template <
class F>
void foreach(F& f) {
49 for (std::list<ReplayRecord>::const_iterator i = buffer.begin(); i != buffer.end(); i++) {
59 std::string destination;
61 ReplayRecord(
const Message& message,
const std::string& destination);
62 void send(MessageReplayTracker&);
69 std::list<ReplayRecord> buffer;
#define QPID_CLIENT_CLASS_EXTERN
AsyncSession_0_10 AsyncSession
AsyncSession is an alias for Session_0_10.
A message sent to or received from the broker.
Utility to track messages sent asynchronously, allowing those that are indoubt to be replayed over a ...
Asynchronous commands that do not return a result will return a Completion.
This file was automatically generated from the AMQP specification.
#define QPID_CLIENT_EXTERN
AMQP 0-10 session API with keyword arguments.