OpenSDN source code
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | Private Attributes | List of all members
ConfigAmqpChannel Class Reference

#include <config_amqp_client.h>

Public Member Functions

 ConfigAmqpChannel ()
 
virtual ~ConfigAmqpChannel ()
 
virtual AmqpClient::Channel::ptr_t CreateFromUri (std::string uri)
 
virtual AmqpClient::Channel::ptr_t CreateSecure (std::string ca_cert, std::string host, std::string client_key, std::string client_cert, int port, std::string username, std::string password, std::string vhost, int frame_max=131072, bool verify_hostname=false)
 
virtual void DeclareExchange (const std::string &exchange_name, const std::string &exchange_type, bool passive, bool durable, bool auto_delete)
 
virtual void DeleteQueue (const std::string &queue_name, bool if_unused, bool if_empty)
 
virtual std::string DeclareQueue (const std::string &queue_name, bool passive, bool durable, bool exclusive, bool auto_delete)
 
virtual void BindQueue (const std::string &queue_name, const std::string &exchange_name, const std::string &routing_key="")
 
virtual std::string BasicConsume (const std::string &queue, const std::string &consumer_tag, bool no_local, bool no_ack, bool exclusive, boost::uint16_t message_prefetch_count)
 
virtual bool BasicConsumeMessage (const std::string &consumer_tag, AmqpClient::Envelope::ptr_t &envelope, int timeout)
 
virtual void BasicAck (const AmqpClient::Envelope::ptr_t &message)
 

Private Attributes

AmqpClient::Channel::ptr_t channel_
 

Detailed Description

Definition at line 21 of file config_amqp_client.h.

Constructor & Destructor Documentation

ConfigAmqpChannel::ConfigAmqpChannel ( )
inline

Definition at line 23 of file config_amqp_client.h.

virtual ConfigAmqpChannel::~ConfigAmqpChannel ( )
inlinevirtual

Definition at line 24 of file config_amqp_client.h.

Member Function Documentation

virtual void ConfigAmqpChannel::BasicAck ( const AmqpClient::Envelope::ptr_t &  message)
inlinevirtual

Definition at line 76 of file config_amqp_client.h.

virtual std::string ConfigAmqpChannel::BasicConsume ( const std::string &  queue,
const std::string &  consumer_tag,
bool  no_local,
bool  no_ack,
bool  exclusive,
boost::uint16_t  message_prefetch_count 
)
inlinevirtual

Definition at line 64 of file config_amqp_client.h.

virtual bool ConfigAmqpChannel::BasicConsumeMessage ( const std::string &  consumer_tag,
AmqpClient::Envelope::ptr_t &  envelope,
int  timeout 
)
inlinevirtual

Definition at line 71 of file config_amqp_client.h.

virtual void ConfigAmqpChannel::BindQueue ( const std::string &  queue_name,
const std::string &  exchange_name,
const std::string &  routing_key = "" 
)
inlinevirtual

Definition at line 58 of file config_amqp_client.h.

virtual AmqpClient::Channel::ptr_t ConfigAmqpChannel::CreateFromUri ( std::string  uri)
inlinevirtual

Definition at line 26 of file config_amqp_client.h.

virtual AmqpClient::Channel::ptr_t ConfigAmqpChannel::CreateSecure ( std::string  ca_cert,
std::string  host,
std::string  client_key,
std::string  client_cert,
int  port,
std::string  username,
std::string  password,
std::string  vhost,
int  frame_max = 131072,
bool  verify_hostname = false 
)
inlinevirtual

Definition at line 30 of file config_amqp_client.h.

virtual void ConfigAmqpChannel::DeclareExchange ( const std::string &  exchange_name,
const std::string &  exchange_type,
bool  passive,
bool  durable,
bool  auto_delete 
)
inlinevirtual

Definition at line 40 of file config_amqp_client.h.

virtual std::string ConfigAmqpChannel::DeclareQueue ( const std::string &  queue_name,
bool  passive,
bool  durable,
bool  exclusive,
bool  auto_delete 
)
inlinevirtual

Definition at line 52 of file config_amqp_client.h.

virtual void ConfigAmqpChannel::DeleteQueue ( const std::string &  queue_name,
bool  if_unused,
bool  if_empty 
)
inlinevirtual

Definition at line 47 of file config_amqp_client.h.

Member Data Documentation

AmqpClient::Channel::ptr_t ConfigAmqpChannel::channel_
private

Definition at line 81 of file config_amqp_client.h.

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