ConfigAmqpClient::RabbitMQReader Class Reference

Inheritance diagram for ConfigAmqpClient::RabbitMQReader:

Collaboration diagram for ConfigAmqpClient::RabbitMQReader:

Public Member Functions
	RabbitMQReader (ConfigAmqpClient *amqpclient)
virtual bool	Run ()
	Code to execute. Returns true if task is completed. Return false to reschedule the task. More...
string	Description () const
Public Member Functions inherited from Task
	Task (int task_id, int task_instance)
	Task (int task_id)
virtual	~Task ()
virtual void	OnTaskCancel ()
	Called on task exit, if it is marked for cancellation. If the user wants to do any cleanup on task cancellation, then he/she can overload this function. More...
State	GetState () const
int	GetTaskId () const
int	GetTaskInstance () const
uint64_t	GetSeqno () const
bool	task_cancelled () const
uint64_t	enqueue_time () const
uint64_t	schedule_time () const
uint32_t	execute_delay () const
uint32_t	schedule_delay () const

Private Member Functions
void	ConnectToRabbitMQ (bool queue_delete=true)
bool	AckRabbitMessages (AmqpClient::Envelope::ptr_t &envelop)
bool	ReceiveRabbitMessages (AmqpClient::Envelope::ptr_t &envelop)

Private Attributes
ConfigAmqpClient *	amqpclient_
boost::scoped_ptr < ConfigAmqpChannel >	channel_
string	consumer_tag_

Additional Inherited Members
Public Types inherited from Task
enum	State { INIT, WAIT, RUN }
	Task states. More...
enum	TbbState { TBB_INIT, TBB_ENQUEUED, TBB_EXEC, TBB_DONE }
Static Public Member Functions inherited from Task
static Task *	Running ()
	Returns a pointer to the current task the code is executing under. More...
Static Public Attributes inherited from Task
static const int	kTaskInstanceAny = -1

Detailed Description

Definition at line 33 of file config_amqp_client.cc.

Constructor & Destructor Documentation

ConfigAmqpClient::RabbitMQReader::RabbitMQReader ( ConfigAmqpClient *  amqpclient )

inline

Definition at line 35 of file config_amqp_client.cc.

Member Function Documentation

bool ConfigAmqpClient::RabbitMQReader::AckRabbitMessages ( AmqpClient::Envelope::ptr_t &  envelop )

private

Definition at line 381 of file config_amqp_client.cc.

void ConfigAmqpClient::RabbitMQReader::ConnectToRabbitMQ ( bool  queue_delete = true )

private

Definition at line 162 of file config_amqp_client.cc.

Here is the call graph for this function:

string ConfigAmqpClient::RabbitMQReader::Description ( ) const

inlinevirtual

Implements Task.

Definition at line 46 of file config_amqp_client.cc.

bool ConfigAmqpClient::RabbitMQReader::ReceiveRabbitMessages ( AmqpClient::Envelope::ptr_t &  envelop )

private

Definition at line 350 of file config_amqp_client.cc.

bool ConfigAmqpClient::RabbitMQReader::Run ( )

virtual

Code to execute. Returns true if task is completed. Return false to reschedule the task.

Implements Task.

Definition at line 408 of file config_amqp_client.cc.

Member Data Documentation

ConfigAmqpClient* ConfigAmqpClient::RabbitMQReader::amqpclient_

private

Definition at line 49 of file config_amqp_client.cc.

boost::scoped_ptr<ConfigAmqpChannel> ConfigAmqpClient::RabbitMQReader::channel_

private

Definition at line 50 of file config_amqp_client.cc.

string ConfigAmqpClient::RabbitMQReader::consumer_tag_

private

Definition at line 51 of file config_amqp_client.cc.

---

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

• config_amqp_client.cc