m2etis
0.4
|
#include <NackDeliver.h>
Public Types | |
typedef message::NackDeliverInfo | DeliverInfoType |
Public Member Functions | |
NackDeliver (PubSubSystemEnvironment *pssi, const typename NetworkType::Key &self) | |
virtual | ~NackDeliver () |
bool | processPublishPayload (typename message::DeliverInfo::Ptr ptr, const typename NetworkType::Key &sender) |
used to process payload More... | |
bool | processNotifyPayload (typename message::DeliverInfo::Ptr ptr, const typename NetworkType::Key &sender) |
used to process payload More... | |
bool | processSubscribePayload (typename message::DeliverInfo::Ptr ptr, const typename NetworkType::Key &sender) |
used to process payload More... | |
bool | processUnsubscribePayload (typename message::DeliverInfo::Ptr ptr, const typename NetworkType::Key &sender) |
used to process payload More... | |
bool | processOtherControlPayload (typename message::DeliverInfo::Ptr ptr, const typename NetworkType::Key &sender) |
creates the DeliverInfo More... | |
void | configureDeliverInfo (uint64_t id, const message::ActionType mtype, typename message::DeliverInfo::Ptr ptr, const typename NetworkType::Key &receiver, message::ControlType ct) |
creates the DeliverInfo More... | |
bool | processControlPayload (typename message::DeliverInfo::Ptr ptr, const typename NetworkType::Key &sender) |
processes Control Messages (id got acked) More... | |
Public Member Functions inherited from m2etis::pubsub::deliver::BaseDeliver< NetworkType > | |
BaseDeliver (PubSubSystemEnvironment *pssi) | |
virtual | ~BaseDeliver () |
void | configureCallback (const boost::function< void(uint64_t, msgProcess)> &func) |
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... | |
void | configureSendCallback (const boost::function< void(message::DeliverInfo::Ptr, const typename NetworkType::Key &, ControlTarget)> &func) |
with this function, new messages can be sent directly to nodes More... | |
Additional Inherited Members | |
Protected Attributes inherited from m2etis::pubsub::deliver::BaseDeliver< NetworkType > | |
PubSubSystemEnvironment * | pssi_ |
PubSubSystemEnvironment. More... | |
boost::function< void(uint64_t, msgProcess)> | process_ |
stores the function to be called for delivering More... | |
boost::function< void(message::DeliverInfo::Ptr, typename NetworkType::Key, ControlTarget)> | sendCtrlMsg_ |
stores the function to send new messages This function will send a newly created control message containing the given DeliverStruct to the specified sender. The Tree ensures that this message will be sent to the specified receiver and will not be processed by any other strategie. More... | |
Definition at line 39 of file NackDeliver.h.
typedef message::NackDeliverInfo m2etis::pubsub::deliver::NackDeliver< NetworkType, Retries, Multiples >::DeliverInfoType |
Definition at line 41 of file NackDeliver.h.
|
inline |
|
inlinevirtual |
Definition at line 47 of file NackDeliver.h.
|
inlinevirtual |
creates the DeliverInfo
Implements m2etis::pubsub::deliver::BaseDeliver< NetworkType >.
Definition at line 86 of file NackDeliver.h.
|
inlinevirtual |
processes Control Messages (id got acked)
Implements m2etis::pubsub::deliver::BaseDeliver< NetworkType >.
Definition at line 102 of file NackDeliver.h.
|
inlinevirtual |
used to process payload
Implements m2etis::pubsub::deliver::BaseDeliver< NetworkType >.
Definition at line 61 of file NackDeliver.h.
|
inlinevirtual |
creates the DeliverInfo
Implements m2etis::pubsub::deliver::BaseDeliver< NetworkType >.
Definition at line 79 of file NackDeliver.h.
|
inlinevirtual |
used to process payload
Implements m2etis::pubsub::deliver::BaseDeliver< NetworkType >.
Definition at line 54 of file NackDeliver.h.
|
inlinevirtual |
used to process payload
Implements m2etis::pubsub::deliver::BaseDeliver< NetworkType >.
Definition at line 68 of file NackDeliver.h.
|
inlinevirtual |
used to process payload
Implements m2etis::pubsub::deliver::BaseDeliver< NetworkType >.
Definition at line 75 of file NackDeliver.h.