MqDestination.hpp

// SPDX-FileCopyrightText: 2026 Vincent Leroy
// SPDX-License-Identifier: MIT
//
// This file is part of dfx.
//
// Licensed under the MIT License. See the LICENSE file in the project root
// for full license information.
 
#pragma once
 
// Project includes
#include "DestinationTransport.hpp"
#include <dfx-utilities/OwnedFd.hpp>
 
namespace dfx::Core
{
class MqDestination : public DestinationTransport
{
public:
    MqDestination(Endpoint endpoint, nlohmann::json config);
 
public:
    void start(FdWatch::Poller & poller) override;

    void stop() noexcept override;

    bool deliver(MessagePtr message) override;

    int64_t pendingMessageCount() const noexcept override;
 
private:
    Utils::OwnedFd _mqfd;
};
} // !namespace dfx:Core