OpenSDN source code
Classes | Public Types | Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes | Static Private Attributes | List of all members
ConfigAmqpClient Class Reference

#include <config_amqp_client.h>

Collaboration diagram for ConfigAmqpClient:
Collaboration graph
[legend]

Classes

class  RabbitMQReader
 

Public Types

typedef boost::asio::ip::tcp::endpoint Endpoint
 

Public Member Functions

 ConfigAmqpClient (ConfigClientManager *mgr, std::string hostname, std::string module_name, const ConfigClientOptions &options)
 
virtual ~ConfigAmqpClient ()
 
void StartRabbitMQReader ()
 
std::string rabbitmq_ip () const
 
std::string rabbitmq_port () const
 
size_t rabbitmq_server_list_len () const
 
void increment_rabbitmq_server_index ()
 
std::string rabbitmq_user () const
 
std::string rabbitmq_password () const
 
std::string rabbitmq_vhost () const
 
bool rabbitmq_use_ssl () const
 
std::string rabbitmq_ssl_version () const
 
std::string rabbitmq_ssl_keyfile () const
 
std::string rabbitmq_ssl_certfile () const
 
std::string rabbitmq_ssl_ca_certs () const
 
ConfigClientManager * config_manager () const
 
ConfigClientManager * config_manager ()
 
std::vector< Endpoint > endpoints () const
 
int reader_task_id () const
 
std::string hostname () const
 
std::string module_name () const
 
std::string FormAmqpUri (bool hide_auth_info) const
 
void EnqueueUUIDRequest (std::string oper, std::string obj_type, std::string uuid_str)
 
bool ProcessMessage (const std::string &json_message)
 
void set_connected (bool connected)
 
void GetConnectionInfo (ConfigAmqpConnInfo &info) const
 
bool terminate () const
 
void set_terminate (bool terminate)
 

Static Public Member Functions

static void set_disable (bool disable)
 

Private Member Functions

void ReportRabbitMQConnectionStatus (bool connected) const
 

Private Attributes

ConfigClientManager * mgr_
 
std::string hostname_
 
std::string module_name_
 
int reader_task_id_
 
size_t current_server_index_
 
bool terminate_
 
std::vector< std::string > rabbitmq_ips_
 
std::vector< std::string > rabbitmq_ports_
 
std::string rabbitmq_user_
 
std::string rabbitmq_password_
 
std::string rabbitmq_vhost_
 
bool rabbitmq_use_ssl_
 
std::string rabbitmq_ssl_version_
 
std::string rabbitmq_ssl_keyfile_
 
std::string rabbitmq_ssl_certfile_
 
std::string rabbitmq_ssl_ca_certs_
 
std::vector< Endpoint > endpoints_
 
tbb::atomic< bool > connection_status_
 
tbb::atomic< uint64_t > connection_status_change_at_
 

Static Private Attributes

static bool disable_
 

Detailed Description

Definition at line 87 of file config_amqp_client.h.

Member Typedef Documentation

◆ Endpoint

typedef boost::asio::ip::tcp::endpoint ConfigAmqpClient::Endpoint

Definition at line 89 of file config_amqp_client.h.

Constructor & Destructor Documentation

◆ ConfigAmqpClient()

ConfigAmqpClient::ConfigAmqpClient ( ConfigClientManager *  mgr,
std::string  hostname,
std::string  module_name,
const ConfigClientOptions &  options 
)

Definition at line 57 of file config_amqp_client.cc.

Here is the call graph for this function:

◆ ~ConfigAmqpClient()

virtual ConfigAmqpClient::~ConfigAmqpClient ( )
inlinevirtual

Definition at line 92 of file config_amqp_client.h.

Member Function Documentation

◆ config_manager() [1/2]

ConfigClientManager* ConfigAmqpClient::config_manager ( )
inline

Definition at line 128 of file config_amqp_client.h.

◆ config_manager() [2/2]

ConfigClientManager* ConfigAmqpClient::config_manager ( ) const
inline

Definition at line 127 of file config_amqp_client.h.

◆ endpoints()

std::vector<Endpoint> ConfigAmqpClient::endpoints ( ) const
inline

Definition at line 129 of file config_amqp_client.h.

◆ EnqueueUUIDRequest()

void ConfigAmqpClient::EnqueueUUIDRequest ( std::string  oper,
std::string  obj_type,
std::string  uuid_str 
)

Definition at line 123 of file config_amqp_client.cc.

Here is the call graph for this function:

◆ FormAmqpUri()

string ConfigAmqpClient::FormAmqpUri ( bool  hide_auth_info) const

Definition at line 130 of file config_amqp_client.cc.

Here is the call graph for this function:

◆ GetConnectionInfo()

void ConfigAmqpClient::GetConnectionInfo ( ConfigAmqpConnInfo &  info) const

Definition at line 250 of file config_amqp_client.cc.

Here is the call graph for this function:

◆ hostname()

std::string ConfigAmqpClient::hostname ( ) const
inline

Definition at line 131 of file config_amqp_client.h.

◆ increment_rabbitmq_server_index()

void ConfigAmqpClient::increment_rabbitmq_server_index ( )
inline

Definition at line 112 of file config_amqp_client.h.

◆ module_name()

std::string ConfigAmqpClient::module_name ( ) const
inline

Definition at line 132 of file config_amqp_client.h.

◆ ProcessMessage()

bool ConfigAmqpClient::ProcessMessage ( const std::string &  json_message)

Definition at line 257 of file config_amqp_client.cc.

Here is the call graph for this function:

◆ rabbitmq_ip()

std::string ConfigAmqpClient::rabbitmq_ip ( ) const
inline

Definition at line 96 of file config_amqp_client.h.

◆ rabbitmq_password()

std::string ConfigAmqpClient::rabbitmq_password ( ) const
inline

Definition at line 120 of file config_amqp_client.h.

◆ rabbitmq_port()

std::string ConfigAmqpClient::rabbitmq_port ( ) const
inline

Definition at line 102 of file config_amqp_client.h.

◆ rabbitmq_server_list_len()

size_t ConfigAmqpClient::rabbitmq_server_list_len ( ) const
inline

Definition at line 108 of file config_amqp_client.h.

◆ rabbitmq_ssl_ca_certs()

std::string ConfigAmqpClient::rabbitmq_ssl_ca_certs ( ) const
inline

Definition at line 126 of file config_amqp_client.h.

◆ rabbitmq_ssl_certfile()

std::string ConfigAmqpClient::rabbitmq_ssl_certfile ( ) const
inline

Definition at line 125 of file config_amqp_client.h.

◆ rabbitmq_ssl_keyfile()

std::string ConfigAmqpClient::rabbitmq_ssl_keyfile ( ) const
inline

Definition at line 124 of file config_amqp_client.h.

◆ rabbitmq_ssl_version()

std::string ConfigAmqpClient::rabbitmq_ssl_version ( ) const
inline

Definition at line 123 of file config_amqp_client.h.

◆ rabbitmq_use_ssl()

bool ConfigAmqpClient::rabbitmq_use_ssl ( ) const
inline

Definition at line 122 of file config_amqp_client.h.

◆ rabbitmq_user()

std::string ConfigAmqpClient::rabbitmq_user ( ) const
inline

Definition at line 119 of file config_amqp_client.h.

◆ rabbitmq_vhost()

std::string ConfigAmqpClient::rabbitmq_vhost ( ) const
inline

Definition at line 121 of file config_amqp_client.h.

◆ reader_task_id()

int ConfigAmqpClient::reader_task_id ( ) const
inline

Definition at line 130 of file config_amqp_client.h.

◆ ReportRabbitMQConnectionStatus()

void ConfigAmqpClient::ReportRabbitMQConnectionStatus ( bool  connected) const
private

Definition at line 143 of file config_amqp_client.cc.

Here is the call graph for this function:

◆ set_connected()

void ConfigAmqpClient::set_connected ( bool  connected)

Definition at line 245 of file config_amqp_client.cc.

Here is the call graph for this function:

◆ set_disable()

static void ConfigAmqpClient::set_disable ( bool  disable)
inlinestatic

Definition at line 134 of file config_amqp_client.h.

◆ set_terminate()

void ConfigAmqpClient::set_terminate ( bool  terminate)
inline

Definition at line 144 of file config_amqp_client.h.

Here is the call graph for this function:

◆ StartRabbitMQReader()

void ConfigAmqpClient::StartRabbitMQReader ( )

Definition at line 102 of file config_amqp_client.cc.

Here is the call graph for this function:

◆ terminate()

bool ConfigAmqpClient::terminate ( ) const
inline

Definition at line 143 of file config_amqp_client.h.

Member Data Documentation

◆ connection_status_

tbb::atomic<bool> ConfigAmqpClient::connection_status_
private

Definition at line 171 of file config_amqp_client.h.

◆ connection_status_change_at_

tbb::atomic<uint64_t> ConfigAmqpClient::connection_status_change_at_
private

Definition at line 172 of file config_amqp_client.h.

◆ current_server_index_

size_t ConfigAmqpClient::current_server_index_
private

Definition at line 157 of file config_amqp_client.h.

◆ disable_

bool ConfigAmqpClient::disable_
staticprivate

Definition at line 169 of file config_amqp_client.h.

◆ endpoints_

std::vector<Endpoint> ConfigAmqpClient::endpoints_
private

Definition at line 170 of file config_amqp_client.h.

◆ hostname_

std::string ConfigAmqpClient::hostname_
private

Definition at line 153 of file config_amqp_client.h.

◆ mgr_

ConfigClientManager* ConfigAmqpClient::mgr_
private

Definition at line 152 of file config_amqp_client.h.

◆ module_name_

std::string ConfigAmqpClient::module_name_
private

Definition at line 154 of file config_amqp_client.h.

◆ rabbitmq_ips_

std::vector<std::string> ConfigAmqpClient::rabbitmq_ips_
private

Definition at line 159 of file config_amqp_client.h.

◆ rabbitmq_password_

std::string ConfigAmqpClient::rabbitmq_password_
private

Definition at line 162 of file config_amqp_client.h.

◆ rabbitmq_ports_

std::vector<std::string> ConfigAmqpClient::rabbitmq_ports_
private

Definition at line 160 of file config_amqp_client.h.

◆ rabbitmq_ssl_ca_certs_

std::string ConfigAmqpClient::rabbitmq_ssl_ca_certs_
private

Definition at line 168 of file config_amqp_client.h.

◆ rabbitmq_ssl_certfile_

std::string ConfigAmqpClient::rabbitmq_ssl_certfile_
private

Definition at line 167 of file config_amqp_client.h.

◆ rabbitmq_ssl_keyfile_

std::string ConfigAmqpClient::rabbitmq_ssl_keyfile_
private

Definition at line 166 of file config_amqp_client.h.

◆ rabbitmq_ssl_version_

std::string ConfigAmqpClient::rabbitmq_ssl_version_
private

Definition at line 165 of file config_amqp_client.h.

◆ rabbitmq_use_ssl_

bool ConfigAmqpClient::rabbitmq_use_ssl_
private

Definition at line 164 of file config_amqp_client.h.

◆ rabbitmq_user_

std::string ConfigAmqpClient::rabbitmq_user_
private

Definition at line 161 of file config_amqp_client.h.

◆ rabbitmq_vhost_

std::string ConfigAmqpClient::rabbitmq_vhost_
private

Definition at line 163 of file config_amqp_client.h.

◆ reader_task_id_

int ConfigAmqpClient::reader_task_id_
private

Definition at line 156 of file config_amqp_client.h.

◆ terminate_

bool ConfigAmqpClient::terminate_
private

Definition at line 158 of file config_amqp_client.h.

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