NonBlockingNotificationRegistration3Base.hpp

//
//  Copyright PHOENIX CONTACT Electronics GmbH
//
 
#pragma once
 
#include "Arp/System/Core/PimplPtr.hxx"
#include "Arp/System/Nm/NonBlockingNotificationRegistration3ArgumentsBufferBase.hpp"
#include "Arp/System/Nm/NonBlockingNotificationSendingAdapter.hpp"
 
namespace Arp { namespace System { namespace Nm
{
 
class NonBlockingNotificationRegistration3Base
{
protected:
    NonBlockingNotificationRegistration3Base();
    explicit NonBlockingNotificationRegistration3Base(
        std::unique_ptr<NonBlockingNotificationSendingAdapter> notificationSending);
    ~NonBlockingNotificationRegistration3Base();
 
public:
    NonBlockingNotificationRegistration3Base(const NonBlockingNotificationRegistration3Base& other) = delete;
    NonBlockingNotificationRegistration3Base(NonBlockingNotificationRegistration3Base&& other) noexcept;
 
    NonBlockingNotificationRegistration3Base& operator=(const NonBlockingNotificationRegistration3Base& other) = delete;
    NonBlockingNotificationRegistration3Base& operator=(NonBlockingNotificationRegistration3Base&& other) noexcept;
 
protected:
    bool HasImpl() const;
 
    NotificationNameIdType GetNotificationNameIdInternal() const;
 
    const Future<NotificationIdType>& GetFutureNotificationId() const;
    void ResetFutureNotificationId();
 
protected:
    void Register(
        const String& notificationName, const String& senderName, Severity severity, PayloadTypeIdType payloadTypeId);
    void Unregister();
    void SendNotificationInternal(const DateTime& timestamp,
                                  std::shared_ptr<NonBlockingNotificationRegistration3ArgumentsBufferBase> argumentsBuffer,
                                  NonBlockingNotificationRegistration3ArgumentsBufferBase::InsertResult argumentsBufferInsertResult,
                                  NonBlockingNotificationSendingAdapter::CreatePayloadFunctor createPayloadFunctor);
 
    bool IsReadyToSend() const;
 
public:
    bool IsCompleted() const;
 
    NotificationIdType GetLastNotificationId() const;
 
private:
    class Impl;
    using Pimpl = PimplPtr<Impl, false>;
    Pimpl pimpl;
};
 
}}} // namespace Arp::System::Nm