NonBlockingNotificationSendingAdapter.hpp

 
//
//  Copyright Phoenix Contact GmbH & Co. KG
//
 
#pragma once
 
#include "Arp/System/Core/Arp.h"
#include "Arp/System/Nm/INonBlockingNotificationSending.hpp"
#include "Arp/System/Nm/NonBlockingNotificationRegistration3ArgumentsBufferBase.hpp"
#include <limits>
#include <memory>
 
namespace Arp { namespace System { namespace Nm
{
 
class NotificationManager;
class NonBlockingNotificationRegistration3ArgumentsBufferBase;
 
class ARP_CXX_SYMBOL_EXPORT NonBlockingNotificationSendingAdapter : public INonBlockingNotificationSending
{
public:
    struct CreatePayloadFunctorArg
    {
        std::shared_ptr<NonBlockingNotificationRegistration3ArgumentsBufferBase> BufferPtr = nullptr;
        size_t Index = std::numeric_limits<size_t>::max();
    };
    using CreatePayloadFunctor = RawPayloadType (*)(CreatePayloadFunctorArg);
 
    explicit NonBlockingNotificationSendingAdapter(NotificationManager& nm);
 
    NotificationNameIdType RegisterNotification(
        const String& notificationName, const String& senderName, Severity severity, PayloadTypeIdType payloadTypeId);
 
    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);
 
    void NonBlockingSendNotification(NotificationNameIdType notificationNameId, Arp::DateTime timestamp,
                                     CreatePayloadFunctor createPayloadFunctor, CreatePayloadFunctorArg createPayloadFunctorArg,
                                     Future<NotificationIdType> result);
 
private:
    NotificationManager& nm;
};
 
}}} // namespace Arp::System::Nm