userver: urabbitmq::IReliableChannelInterface Class Reference
Loading...
Searching...
No Matches
urabbitmq::IReliableChannelInterface Class Referenceabstract

#include <userver/urabbitmq/broker_interface.hpp>

Detailed Description

Reliable publisher interface for the broker. This class is merely an interface for convenience and you are not expected to use it directly (use Client/ReliableChannel instead).

Definition at line 133 of file broker_interface.hpp.

+ Inheritance diagram for urabbitmq::IReliableChannelInterface:

Public Member Functions

virtual void PublishReliable (const Exchange &exchange, const std::string &routing_key, const std::string &message, MessageType type, engine::Deadline deadline)=0
 Publish a message to an exchange and await confirmation from the broker.
 
virtual void PublishReliable (const Exchange &exchange, const std::string &routing_key, const std::string &message, engine::Deadline deadline)=0
 overload of PublishReliable
 

Member Function Documentation

◆ PublishReliable() [1/2]

virtual void urabbitmq::IReliableChannelInterface::PublishReliable ( const Exchange & exchange,
const std::string & routing_key,
const std::string & message,
engine::Deadline deadline )
pure virtual

overload of PublishReliable

Implemented in urabbitmq::ReliableChannel, and urabbitmq::Client.

◆ PublishReliable() [2/2]

virtual void urabbitmq::IReliableChannelInterface::PublishReliable ( const Exchange & exchange,
const std::string & routing_key,
const std::string & message,
MessageType type,
engine::Deadline deadline )
pure virtual

Publish a message to an exchange and await confirmation from the broker.

You have to supply the name of the exchange and a routing key. RabbitMQ will then try to send the message to one or more queues. By default unroutable messages are silently discarded

Parameters
exchangethe exchange to publish to
routing_keythe routing key
messagethe message to send
deadlineexecution deadline

Implemented in urabbitmq::ReliableChannel, and urabbitmq::Client.


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