#include <mqueue.h>
Definition at line 11 of file mqueue.h.
Public Member Functions | |
MessageQueue (unsigned int nodeSize=256) | |
void | IsolatedInitialize (const NameValuePairs ¶meters) |
unsigned int | Put2 (const byte *begin, unsigned int length, int messageEnd, bool blocking) |
bool | IsolatedFlush (bool hardFlush, bool blocking) |
bool | IsolatedMessageSeriesEnd (bool blocking) |
unsigned long | MaxRetrievable () const |
bool | AnyRetrievable () const |
unsigned int | TransferTo2 (BufferedTransformation &target, unsigned long &transferBytes, const std::string &channel=NULL_CHANNEL, bool blocking=true) |
unsigned int | CopyRangeTo2 (BufferedTransformation &target, unsigned long &begin, unsigned long end=ULONG_MAX, const std::string &channel=NULL_CHANNEL, bool blocking=true) const |
unsigned long | TotalBytesRetrievable () const |
unsigned int | NumberOfMessages () const |
bool | GetNextMessage () |
unsigned int | NumberOfMessagesInThisSeries () const |
unsigned int | NumberOfMessageSeries () const |
unsigned int | CopyMessagesTo (BufferedTransformation &target, unsigned int count=UINT_MAX, const std::string &channel=NULL_CHANNEL) const |
const byte * | Spy (unsigned int &contiguousSize) const |
void | swap (MessageQueue &rhs) |