conduit::mqtt::Transport Class Reference

MQTT pipe — one instance binds to a single MQTT topic and carries traffic in both directions: outbound dispatch() calls publish onto the topic, and any inbound message on the topic is decoded via the shared event registry and delivered through the inbound sink installed at attach time. More...

#include <transport.hpp>

Inheritance diagram for conduit::mqtt::Transport:

Collaboration diagram for conduit::mqtt::Transport:

Public Member Functions
	Transport (Config config, std::shared_ptr< EventRegistry > registry={})
	Construct an MQTT pipe.
	Transport (const Transport &)=delete
Transport &	operator= (const Transport &)=delete
	Transport (Transport &&)=delete
Transport &	operator= (Transport &&)=delete
	~Transport () override
TransportScope	scope () const noexcept override
void	attach_with_sink (Bus &bus, InboundSink sink) override
	Attach to a bus using a caller-supplied inbound sink.
void	detach () noexcept override
void	dispatch (const EventEnvelopeView &v) override
void	flush () override
bool	is_connected () const noexcept
Public Member Functions inherited from conduit::Transport
	Transport ()=default
	Transport (const Transport &)=delete
	Transport (Transport &&) noexcept=default
Transport &	operator= (const Transport &)=delete
Transport &	operator= (Transport &&) noexcept=default
	~Transport () override=default
virtual void	attach (Bus &bus)
	Attach to a bus.

Additional Inherited Members
Protected Member Functions inherited from conduit::Transport
void	deliver_inbound (const EventEnvelopeView &v) const
	Subclasses call this for inbound delivery instead of touching the bus directly.
Bus *	bus () const noexcept

Detailed Description

MQTT pipe — one instance binds to a single MQTT topic and carries traffic in both directions: outbound dispatch() calls publish onto the topic, and any inbound message on the topic is decoded via the shared event registry and delivered through the inbound sink installed at attach time.

Constructor & Destructor Documentation

Transport() [1/3]

conduit::mqtt::Transport::Transport ( Config  config, std::shared_ptr< EventRegistry >  registry = {}  )

explicit

Construct an MQTT pipe.

By default, decoding uses the bus's registry — pass an explicit registry to scope a transport to a restricted set of event types (e.g. an audit pipe that only deserializes audit cells).

Transport() [2/3]

conduit::mqtt::Transport::Transport ( const Transport &  )

delete

Transport() [3/3]

conduit::mqtt::Transport::Transport ( Transport &&  )

delete

~Transport()

conduit::mqtt::Transport::~Transport ( )

override

Member Function Documentation

attach_with_sink()

void conduit::mqtt::Transport::attach_with_sink ( Bus &  bus, InboundSink  sink  )

overridevirtual

Attach to a bus using a caller-supplied inbound sink.

Wrappers use this to intercept the inbound leg without each transport needing to re-implement the hook.

Reimplemented from conduit::Transport.

detach()

void conduit::mqtt::Transport::detach ( )

overridevirtualnoexcept

Reimplemented from conduit::Transport.

dispatch()

void conduit::mqtt::Transport::dispatch ( const EventEnvelopeView &  v )

overridevirtual

Implements conduit::Transport.

flush()

void conduit::mqtt::Transport::flush ( )

overridevirtual

Reimplemented from conduit::Transport.

is_connected()

bool conduit::mqtt::Transport::is_connected ( ) const

noexcept

operator=() [1/2]

Transport & conduit::mqtt::Transport::operator= ( const Transport &  )

delete

operator=() [2/2]

Transport & conduit::mqtt::Transport::operator= ( Transport &&  )

delete

scope()

TransportScope conduit::mqtt::Transport::scope ( ) const

inlineoverridevirtualnoexcept

Implements conduit::Transport.

---

The documentation for this class was generated from the following file:

• transports/mqtt/include/conduit/mqtt/transport.hpp