NotificationSubscriber.hpp

//
//  Copyright PHOENIX CONTACT Electronics GmbH
//
 
#pragma once
 
#include "Arp/System/Core/event.hxx"
#include "Arp/System/Commons/Diagnostics/Logging/Loggable.hxx"
#include "Arp/System/Commons/Threading/Mutex.hpp"
#include "Arp/System/Nm/INotificationReceiving.hpp"
#include "Arp/System/Nm/INotificationSubscriber.hpp"
 
namespace Arp { namespace System { namespace Nm
{
 
 
class NotificationSubscriber
    : public INotificationSubscriber
    , public Arp::System::Commons::Diagnostics::Logging::Loggable<NotificationSubscriber>
{
public:
    NotificationSubscriber() = default;
 
    ARP_DEPRECATED("Use NotificationSubscriber(notificationName) instead. notificationReceiving is ignored.")
    NotificationSubscriber(
        const String& notificationName, INotificationReceiving& notificationReceiving);
 
    explicit NotificationSubscriber(const String& notificationName);
 
    NotificationSubscriber(const NotificationSubscriber&) = delete;
    NotificationSubscriber(NotificationSubscriber&& other);
    ~NotificationSubscriber() override;
 
    NotificationSubscriber& operator=(const NotificationSubscriber&) = delete;
    NotificationSubscriber& operator=(NotificationSubscriber&& other);
 
    Arp::event<const Notification&> OnNotification;
 
    void Dispose() noexcept;
 
    void Notify(const Notification& notification) override;
 
    const String GetNotificationName() const;
 
    const NotificationNameIdType GetNotificationNameId() const;
 
private: // methods
    void Initialize();
    bool IsInitialized() const;
    void TranferSubscriptionFrom(NotificationSubscriber& other);
 
private: // fields
 
    // NotificationReceiving is not used any more. It will be removed in future versions.
    INotificationReceiving* NotificationReceiving = nullptr;
 
    String NotificationName;
    NotificationNameIdType NotificationNameId;
 
    // Mutex is not used any more. It will be removed in future versions.
    Arp::System::Commons::Threading::Mutex Mutex;
};
 
}}} // namespace Arp::System::Nm