Public Member Functions
virtual void	publish (const std::string &message)=0

virtual void	subscribe (MessageHandler handler, const std::string &topic="", const std::string &action="")=0

virtual std::shared_ptr< MessageStream >	openStream (const std::string &streamId, MessageStream::Mode mode)=0

Detailed Description

MessageBroker should be extended to handle sending and receiving messages to and from the Engine.

Member Function Documentation

virtual void aace::core::MessageBroker::publish ( const std::string & message )

pure virtual

Publishes a message to the Engine.

Parameters

[in] message The message.

virtual void aace::core::MessageBroker::subscribe	(	MessageHandler	handler,
		const std::string &	topic = `""`,
		const std::string &	action = `""`
	)

pure virtual

Subscribes to messages that are sent from the Engine.

Parameters

[in]	handler	The message handler.
[in]	topic	Message topic to subscribe to.
[in]	action	Message action to subscribe to.

virtual std::shared_ptr<MessageStream> aace::core::MessageBroker::openStream	(	const std::string &	streamId,
		MessageStream::Mode	mode
	)

pure virtual

Opens an message stream that has been registered by the Engine.

Parameters

[in]	streamId	The `id` of the stream being opened.
[in]	mode	The stream operation @ mode being requested.