Consumer interface.
More...
#include <gu_prodcons.hpp>
const Message* gu::prodcons::Consumer::get_next_msg |
( |
| ) |
|
|
protected |
Get the first message from the message queue.
Get the first message from the message queue. Note that this method does not remove the first message from message queue.
- Returns
- Next message from the message queue
void gu::prodcons::Consumer::queue_and_wait |
( |
const Message & |
msg, |
|
|
Message * |
ack |
|
) |
| |
Queue message and wait for ack.
- Parameters
-
[in] | msg | Message to be queued |
[out] | ack | Ack returned by consumer |
void gu::prodcons::Consumer::return_ack |
( |
const Message & |
msg | ) |
|
|
protected |
Return ack message for the producer.
Return ack message for the producer. Note that this method pops the first message from the message queue.
- Parameters
-
msg | Ack message corresponding the current head of mque |
The documentation for this class was generated from the following file:
- /wrkdirs/usr/ports/databases/galera/work/galera-25.3.5-src/galerautils/src/gu_prodcons.hpp