gz/sim/comms/Broker.hh
This library is part of the Gazebo project.
std::chrono::steady_clock::duration Time() const
Get the current time.
void OnUnbind(const ignition::msgs::StringMsg_V &_req)
Unbind a given client address. The client associated to this address will not receive any more messag...
void SetTime(const std::chrono::steady_clock::duration &_time)
Set the current time.
bool OnBind(const ignition::msgs::StringMsg_V &_req, ignition::msgs::Boolean &_rep)
This method associates an address with a client topic used as callback for receiving messages....
void Load(std::shared_ptr< const sdf::Element > _sdf)
Configure the broker via SDF.
MsgManager & DataManager()
Get a mutable reference to the message manager.
A class to store messages to be delivered using a comms model. This class should be used in combinati...
Definition: gz/sim/comms/Broker.hh:85
void OnMsg(const ignition::msgs::Dataframe &_msg)
Callback executed to process a communication request from one of the clients.
void DeliverMsgs()
Process all the messages in the inbound queue and deliver them to the destination clients.
Class to handle messages and subscriptions.
Definition: gz/sim/comms/MsgManager.hh:78