Message broker. More...

#include <message_broker.h>

Classes
class	subscription

Public Types
typedef etl::span< const etl::message_id_t >	message_id_span_t

Public Types inherited from etl::imessage_router
enum	{ NULL_MESSAGE_ROUTER = 255 , MESSAGE_BUS = 254 , ALL_MESSAGE_ROUTERS = 253 , MESSAGE_BROKER = 252 , MESSAGE_ROUTER = 251 , MAX_MESSAGE_ROUTER = 249 }

enum	{ NULL_MESSAGE_ROUTER = 255 , MESSAGE_BUS = 254 , ALL_MESSAGE_ROUTERS = 253 , MESSAGE_BROKER = 252 , MESSAGE_ROUTER = 251 , MAX_MESSAGE_ROUTER = 249 }

Public Types inherited from etl::successor< imessage_router >
typedef imessage_router	successor_type

Public Member Functions
	message_broker ()
	Constructor.

	message_broker (etl::imessage_router &successor_)
	Constructor.

	message_broker (etl::message_router_id_t id_)
	Constructor.

	message_broker (etl::message_router_id_t id_, etl::imessage_router &successor_)
	Constructor.

void	subscribe (etl::message_broker::subscription &new_sub)
	Subscribe to the broker.

void	unsubscribe (etl::imessage_router &router)

virtual void	receive (const etl::imessage &msg) ETL_OVERRIDE

virtual void	receive (etl::shared_message shared_msg) ETL_OVERRIDE

virtual void	receive (etl::message_router_id_t destination_router_id, const etl::imessage &msg) ETL_OVERRIDE

virtual void	receive (etl::message_router_id_t destination_router_id, etl::shared_message shared_msg) ETL_OVERRIDE

virtual bool	accepts (etl::message_id_t id) const ETL_OVERRIDE

void	clear ()

virtual ETL_DEPRECATED bool	is_null_router () const ETL_OVERRIDE

virtual bool	is_producer () const ETL_OVERRIDE

virtual bool	is_consumer () const ETL_OVERRIDE

bool	empty () const

virtual bool	accepts (etl::message_id_t) const=0

bool	accepts (const etl::imessage &msg) const

virtual bool	accepts (etl::message_id_t) const=0

bool	accepts (const etl::imessage &msg) const

Public Member Functions inherited from etl::imessage_router
bool	accepts (const etl::imessage &msg) const

etl::message_router_id_t	get_message_router_id () const

bool	accepts (const etl::imessage &msg) const

etl::message_router_id_t	get_message_router_id () const

Public Member Functions inherited from etl::successor< imessage_router >
	successor ()
	Default constructor.

	successor (successor_type &s)
	Construct from a successor type.

void	set_successor (successor_type &s)
	Set the successor.

void	append_successor (TSuccessor &s)
	Append a successor.

void	clear_successor ()
	Clear the successor.

void	clear_successor_chain ()
	Clear the successor chain.

successor_type &	get_successor () const

bool	has_successor () const
	Does this have a successor?

Additional Inherited Members
Protected Member Functions inherited from etl::imessage_router
	imessage_router (etl::message_router_id_t id_)

	imessage_router (etl::message_router_id_t id_, imessage_router &successor_)

	imessage_router (etl::message_router_id_t id_)

	imessage_router (etl::message_router_id_t id_, imessage_router &successor_)