9#include "plugin_base.h"
11namespace rotor::plugin {
27 const std::type_index &
identity() const noexcept override;
69 template <typename T> auto &
access() noexcept;
77 bool ready_to_shutdown() noexcept;
namespace for rotor core messages (which just transform payloads)
Definition messages.hpp:317
intrusive_ptr_t< handler_base_t > handler_ptr_t
intrusive pointer for handler
Definition forward.hpp:26
intrusive_ptr_t< address_t > address_ptr_t
intrusive pointer for address
Definition address.hpp:57
intrusive_ptr_t< subscription_info_t > subscription_info_ptr_t
intrusive pointer for subscription_info_t
Definition subscription_point.h:121
universal primitive of concurrent computation
Definition actor_base.h:47
manages all actor subscriptions (i.e. from plugins or actor itself).
Definition lifetime.h:21
virtual void on_unsubscription_external(message::unsubscription_external_t &) noexcept
reaction on external unsubscription
const std::type_index & identity() const noexcept override
returns pointer, which uniquely identifiess plugin type
bool handle_unsubscription(const subscription_point_t &point, bool external) noexcept override
polls plugin, whether it is done with unsubscription
plugin_base_t()=default
default plugin ctor
static const std::type_index class_identity
Definition lifetime.h:25
void unsubscribe(const handler_ptr_t &h, const address_ptr_t &addr) noexcept
alias for unsubscription trigger (see below)
virtual void on_subscription(message::subscription_t &) noexcept
reaction on subscription
void initate_subscription(const subscription_info_ptr_t &info) noexcept
records initial subscription information
void deactivate() noexcept override
deactivates plugin from an actor
virtual void on_unsubscription(message::unsubscription_t &) noexcept
reaction on unsubscription
bool handle_shutdown(message::shutdown_request_t *message) noexcept override
polls plugin, whether it is done with shutdown
void activate(actor_base_t *actor) noexcept override
invoked by actor upon initialization.
auto & access() noexcept
generic non-public fields accessor
plugin_base_t()=default
default plugin ctor
actor_base_t * actor
non-owning actor pointer
Definition plugin_base.h:179
list of subscription_info_ptr_t with possibility to find via subscription_point_t
Definition subscription_point.h:126
pair of handler_base_t linked to particular address_t
Definition subscription_point.h:49
Holds and classifies message handlers on behalf of supervisor.
Definition subscription.h:30