MqSource.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 "SourceTransport.hpp"
#include <dfx-fdwatch/PollerFd.hpp>
 
namespace dfx::Core
{
class MqSource : public SourceTransport
{
public:
    MqSource(Endpoint endpoint, nlohmann::json config);
 
public:
    void start(FdWatch::Poller & poller) override;

    void stop() noexcept override;
 
private:
    void _onReadyRead(FdWatch::EventTriggers events);
 
private:
    FdWatch::PollerFd _mqfd;
    std::size_t _messageMaxSize;
};
} // !namespace dfx::Core