Updated QueuedMessageRouter example.

This commit is contained in:
John Wellbelove 2021-05-24 11:53:09 +01:00
parent 42546176a9
commit d437377310

View File

@ -92,32 +92,32 @@ public:
// Call the base class's receive function. // Call the base class's receive function.
// This will route it to the correct on_receive handler. // This will route it to the correct on_receive handler.
Base_t::receive(sender, msg); Base_t::receive(msg);
queue.pop(); queue.pop();
} }
} }
//*************************************************************************** //***************************************************************************
void on_receive(etl::imessage_router& sender, const Message1& msg) void on_receive(const Message1& msg)
{ {
std::cout << " Received message " << int(msg.get_message_id()) << " : '" << msg.i << "'" << std::endl; std::cout << " Received message " << int(msg.get_message_id()) << " : '" << msg.i << "'" << std::endl;
} }
//*************************************************************************** //***************************************************************************
void on_receive(etl::imessage_router& sender, const Message2& msg) void on_receive(const Message2& msg)
{ {
std::cout << " Received message " << int(msg.get_message_id()) << " : '" << msg.d << "'" << std::endl; std::cout << " Received message " << int(msg.get_message_id()) << " : '" << msg.d << "'" << std::endl;
} }
//*************************************************************************** //***************************************************************************
void on_receive(etl::imessage_router& sender, const Message3& msg) void on_receive(const Message3& msg)
{ {
std::cout << " Received message " << int(msg.get_message_id()) << " : '" << msg.s << "'" << std::endl; std::cout << " Received message " << int(msg.get_message_id()) << " : '" << msg.s << "'" << std::endl;
} }
//*************************************************************************** //***************************************************************************
void on_receive_unknown(etl::imessage_router& sender, const etl::imessage& msg) void on_receive_unknown(const etl::imessage& msg)
{ {
std::cout << " Received unknown message " << int(msg.get_message_id()) << std::endl; std::cout << " Received unknown message " << int(msg.get_message_id()) << std::endl;
} }