Protected Attributes inherited from m2etis::pubsub::order::BaseOrder Several strategies need this to determind the sequencer More. With this function, new messages can be sent directly to nodes More. Sets the hostname of the current node More.ĬonfigureSendCallback (const boost::function &func) SetHn (const typename NetworkType::Key &self) Used to set the function to be called when a message should be send to the next processing stage call this function with the id given in receive() to deliver the appropriate message More. Public Member Functions inherited from m2etis::pubsub::order::BaseOrderīaseOrder ( PubSubSystemEnvironment *pssi, bool isRoot)ĬonfigureCallback (const boost::function &func) Notified when message dropped by filter or validity strategy More. NotifyRemovedMessage (typename message::OrderInfo::Ptr ptr, const typename NetworkType::Key &receiver) Receives a message stores the message in the queue and wait for it's deliver More. Receive (uint64_t id, typename message::OrderInfo::Ptr ptr, const typename NetworkType::Key &) ProcessNotifyPayload (typename message::OrderInfo::Ptr ptr, const typename NetworkType::Key &)Ĭalled for every NotifyMsg that arrived More. ProcessPublishPayload (typename message::OrderInfo::Ptr, const typename NetworkType::Key &) ProcessSubscribePayload (typename message::OrderInfo::Ptr, const typename NetworkType::Key &)
ProcessControlPayload (typename message::OrderInfo::Ptr ptr, const typename NetworkType::Key &sender) Used to manage sending a message All messages but Publish messages can be sent directly without any special treatment Publish messages however need to be stored until a sequence number is available More. Pending messages if the buffer is non-empty More.ĬonfigureOrderInfo (uint64_t id, const message::ActionType mtype, typename message::OrderInfo::Ptr ptr, const typename NetworkType::Key &rec) MTPOrder ( PubSubSystemEnvironment *pssi, bool b)
0 kommentar(er)
