#include <conexus/messagequeue.h>
Inheritance diagram for Conexus::MessageQueue:
Public Types | |
typedef ConexusPointer< MessageQueue > | pointer |
Public Member Functions | |
virtual void | open () throw ( open_exception ) |
virtual void | close (bool force=false) throw ( close_exception ) |
const std::string & | name () const |
void | set_name (const std::string &name) |
unsigned | flags () const |
void | set_flags (unsigned flags) |
bool | unlink_on_destruction () |
void | set_unlink_on_destruction (bool u=true) |
long int | max_messages () |
long int | max_message_size () |
Static Public Member Functions | |
static MessageQueue::pointer | create (const std::string &name, unsigned flags=QUEUE_READ|QUEUE_WRITE|QUEUE_CREATE, mode_t mode=S_IRWXU, bool close_on_destruction=true) |
Protected Member Functions | |
MessageQueue (const std::string &name, unsigned flags, mode_t mode, bool close_on_destruction) | |
virtual ssize_t | write_data (long int timeout, const Data data) throw ( write_exception ) |
virtual Data | read_data (long int timeout, size_t s=0) throw ( read_exception ) |
Protected Attributes | |
std::string | m_name |
unsigned | m_flags |
bool | m_unlink_on_destruction |
long int | m_max_messages |
long int | m_max_message_size |
mode_t | m_mode |
mqd_t | m_queue |