msgbus.hpp File Reference

EII Message Bus C++ API. More...

#include <atomic>
#include <string>
#include <chrono>
#include <thread>
#include <condition_variable>
#include <eii/utils/profiling.h>
#include <eii/utils/thread_safe_queue.h>
#include "eii/msgbus/msgbus.h"
#include "eii/msgbus/msg_envelope.hpp"

Go to the source code of this file.

Classes
class	eii::msgbus::MsgbusContext
class	eii::msgbus::ReceiveContext
class	eii::msgbus::Service
class	eii::msgbus::ServiceRequester
class	eii::msgbus::Publisher
class	eii::msgbus::BaseMsgbusThread
class	eii::msgbus::PublisherThread
class	eii::msgbus::SubscriberThread< T >

Typedefs
typedef ReceiveContext	eii::msgbus::Subscriber
typedef eii::utils::ThreadSafeQueue< eii::msgbus::Serializable * >	eii::msgbus::MessageQueue

Detailed Description

EII Message Bus C++ API.

Typedef Documentation

MessageQueue

typedef eii::utils::ThreadSafeQueue<eii::msgbus::Serializable*> eii::msgbus::MessageQueue

Thread safe queue for serializable objects.

Subscriber

typedef ReceiveContext eii::msgbus::Subscriber

EII Message Bus Subscriber wrapper.

Note

This is just a typedef, because it has no differences with a ReceiveContext object.