coffee/etl
1
0
Fork 0
mirror of https://github.com/ETLCPP/etl.git synced 2026-06-16 17:06:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

message router changes

Browse Source
This commit is contained in:
John Wellbelove 2021-01-03 20:24:38 +00:00
parent 6e71e05877
commit fc48021849
4 changed files with 16 additions and 43 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
include/etl/fsm.h
View File

@ -266,26 +266,6 @@ namespace etl
}
}
//*******************************************
/// Top level message handler for the FSM.
//*******************************************
void receive(const etl::imessage& message) ETL_OVERRIDE
{
static etl::null_message_router nmr;
receive(nmr, message);
}
//*******************************************
/// Top level message handler for the FSM.
//*******************************************
void receive(imessage_router& source, etl::message_router_id_t destination_router_id, const etl::imessage& message) ETL_OVERRIDE
{
if ((destination_router_id == get_message_router_id()) || (destination_router_id == imessage_router::ALL_MESSAGE_ROUTERS))
{
receive(source, message);
}
}
//*******************************************
/// Top level message handler for the FSM.
//*******************************************

15
include/etl/generators/message_router_generator.h
View File

@ -129,14 +129,7 @@ namespace etl
virtual bool is_producer() const = 0;
virtual bool is_consumer() const = 0;
//********************************************
void receive(const etl::imessage& message)
{
receive(etl::get_null_message_router(), message);
}
//********************************************
void receive(imessage_router& source, etl::message_router_id_t destination_router_id, const etl::imessage& message)
virtual void receive(imessage_router& source, etl::message_router_id_t destination_router_id, const etl::imessage& message)
{
if ((destination_router_id == get_message_router_id()) || (destination_router_id == imessage_router::ALL_MESSAGE_ROUTERS))
{
@ -144,6 +137,12 @@ namespace etl
}
}
//********************************************
void receive(const etl::imessage& message)
{
receive(etl::get_null_message_router(), message);
}
//********************************************
virtual void receive(imessage_router& source, etl::shared_message shared_msg)
{

7
include/etl/message_bus.h
View File

@ -147,13 +147,6 @@ namespace etl
}
}
//*******************************************
void receive(const etl::imessage& message) ETL_OVERRIDE
{
etl::null_message_router nmr;
receive(nmr, etl::imessage_router::ALL_MESSAGE_ROUTERS, message);
}
//*******************************************
void receive(etl::message_router_id_t destination_router_id,
const etl::imessage& message)

17
include/etl/message_router.h
View File

@ -118,20 +118,21 @@ namespace etl
virtual bool is_consumer() const = 0;
//********************************************
void receive(const etl::imessage& message)
{
receive(etl::get_null_message_router(), message);
}
//********************************************
void receive(imessage_router& source, etl::message_router_id_t destination_router_id, const etl::imessage& message)
virtual void receive(imessage_router& source, etl::message_router_id_t destination_router_id, const etl::imessage& message)
{
if ((destination_router_id == get_message_router_id()) || (destination_router_id == imessage_router::ALL_MESSAGE_ROUTERS))
{
receive(source, message);
}
}
//********************************************
void receive(const etl::imessage& message)
{
receive(etl::get_null_message_router(), message);
}
//********************************************
virtual void receive(imessage_router& source, etl::shared_message shared_msg)
{