Message handler for subscription protocol messages. More...

Inheritance diagram for subscription_handler:

Collaboration diagram for subscription_handler:

Public Member Functions
	subscription_handler (std::shared_ptr< subscription_manager > manager)
	Construct a subscription handler.

boost::asio::awaitable< std::expected< std::vector< std::byte >, messaging::error_code > >	handle_message (messaging::message_type type, std::span< const std::byte > payload, const std::string &remote_address) override
	Handle a subscription protocol message.

Detailed Description

Message handler for subscription protocol messages.

Handles subscribe_request and unsubscribe_request messages from clients, delegating to the subscription_manager to track subscriptions.

Note: notification messages are server-initiated and are sent via the subscription_manager's notify() method, not through this handler.

Constructor & Destructor Documentation

subscription_handler ( std::shared_ptr< subscription_manager > manager )

explicit

Construct a subscription handler.

Parameters

manager Shared subscription manager for tracking subscriptions.

boost::asio::awaitable< std::expected< std::vector< std::byte >, messaging::error_code > > handle_message	(	messaging::message_type	type,
		std::span< const std::byte >	payload,
		const std::string &	remote_address
	)

overridevirtual

Handle a subscription protocol message.

Parameters

type	The message type (subscribe_request or unsubscribe_request).
payload	The message payload.
remote_address	The remote endpoint address of the client.