12#include "SourceTransport.hpp"
44 void stop() noexcept
override {}
A synchronous, in-process source transport.
Definition LocalSource.hpp:28
SourceTransport(Endpoint endpoint, nlohmann::json config)
Constructs a SourceTransport with the Role::Source role.
Definition SourceTransport.hpp:31
bool send(MessagePtr message)
Synchronously pushes a message into the channel.
Definition LocalSource.hpp:39
void start(FdWatch::Poller &) override
Activates the transport and begins I/O operations.
Definition LocalSource.hpp:43
void stop() noexcept override
Deactivates the transport and releases system resources.
Definition LocalSource.hpp:44
SourceTransport(Endpoint endpoint, nlohmann::json config)
Constructs a SourceTransport with the Role::Source role.
Definition SourceTransport.hpp:31
bool transmitMessage(MessagePtr message)
Forwards a message to the attached Channel for orchestration.
Abstract interface for FD-based event polling.
Definition Poller.hpp:37
Definition Channel.hpp:25
std::unique_ptr< Message > MessagePtr
Unique ownership handle for messages.
Definition Message.hpp:27