NonBlockingNotificationSendingAdapter.hpp

//
//  Copyright PHOENIX CONTACT Electronics GmbH
//


#pragma once


#include "Arp/System/Nm/INonBlockingNotificationSending.hpp"


namespace Arp { namespace System { namespace Nm
{

class NotificationManager;


class NonBlockingNotificationSendingAdapter : public INonBlockingNotificationSending
{
public:
    explicit NonBlockingNotificationSendingAdapter(NotificationManager& nm);

    Future<NotificationNameIdType> NonBlockingRegisterNotification(const String& notificationName,
            const String& senderName, Severity severity, PayloadTypeIdType payloadTypeId) override;

    void NonBlockingRegisterNotification(const String& notificationName, const String& senderName,
                                         Severity severity, PayloadTypeIdType payloadTypeId, Future<NotificationNameIdType> result);

    Future<void> NonBlockingUnregisterNotification(
        NotificationNameIdType notificationNameId) override;

    void NonBlockingUnregisterNotification(
        NotificationNameIdType notificationNameId, Future<void> result);

    Future<NotificationIdType> NonBlockingSendNotification(
        NotificationNameIdType notificationNameId, Arp::DateTime timestamp,
        const RawPayloadType& payload) override;

    Future<NotificationIdType> NonBlockingSendNotification(
        NotificationNameIdType notificationNameId, Arp::DateTime timestamp,
        const IPayload& payload) override;

    void NonBlockingSendNotification(NotificationNameIdType notificationNameId,
                                     Arp::DateTime timestamp, std::function<RawPayloadType()> createPayloadFunctor,
                                     Future<NotificationIdType> result);

private:
    NotificationManager& nm;
};

}}} // namespace Arp::System::Nm