|
libmoost
|
Public Member Functions | |
| int | run (int argc, char *argv[]) |
| std::string | show_help () const |
| std::string | get_prompt () const |
| bool | handle_command (std::string &rv, const std::string &cmd, const std::string &args) |
Static Public Member Functions | |
| stomp_test_client () | |
Private Types | |
| typedef void(stomp_test_client::* | cmd_method_t )(const std::vector< std::string > &, std::ostream &) |
Private Member Functions | |
| void | show_help (po::options_description &opt) const |
| bool | init (int argc, char *argv[]) |
| void | parse_options (const std::vector< std::string > &args, const po::options_description &od, const po::positional_options_description &pd, po::variables_map &vm) |
| void | error_callback (const boost::system::error_code &ec, const std::string &str) |
| void | message_callback (const std::string &topic, const std::string &msg) |
| bool | simple_command_help (const std::string &name, const std::vector< std::string > &args, std::ostream &os) |
| template<typename Func > | |
| void | simple_command (const std::string &name, Func func, const std::vector< std::string > &args, std::ostream &os) |
| void | connect (const std::vector< std::string > &args, std::ostream &os) |
| void | subscribe (const std::vector< std::string > &args, std::ostream &os) |
| void | unsubscribe (const std::vector< std::string > &args, std::ostream &os) |
| void | send (const std::vector< std::string > &args, std::ostream &os) |
| void | disconnect (const std::vector< std::string > &args, std::ostream &os) |
| void | reset (const std::vector< std::string > &args, std::ostream &os) |
| void | status (const std::vector< std::string > &args, std::ostream &os) |
| void | num_processed (const std::vector< std::string > &args, std::ostream &os) |
| void | num_pending (const std::vector< std::string > &args, std::ostream &os) |
| bool | run_command (cmd_method_t meth, std::string &rv, const std::vector< std::string > &av, std::ostream &os) |
| void | process () |
| void | reset_client () |
Private Attributes | |
| size_t | m_consumer_pool_size |
| float | m_keepalive_interval |
| float | m_reconnect_interval |
| std::string | m_default_log_level |
| std::string | m_logging_config |
| boost::shared_ptr < moost::mq::stomp_client > | m_client |
Definition at line 53 of file stomp_test_client.cpp.
typedef void(stomp_test_client::* stomp_test_client::cmd_method_t)(const std::vector< std::string > &, std::ostream &) [private] |
Definition at line 140 of file stomp_test_client.cpp.
| stomp_test_client::stomp_test_client | ( | ) | [inline, static] |
Definition at line 56 of file stomp_test_client.cpp.
| void stomp_test_client::connect | ( | const std::vector< std::string > & | args, |
| std::ostream & | os | ||
| ) | [inline, private] |
Definition at line 239 of file stomp_test_client.cpp.


| void stomp_test_client::disconnect | ( | const std::vector< std::string > & | args, |
| std::ostream & | os | ||
| ) | [inline, private] |
Definition at line 355 of file stomp_test_client.cpp.


| void stomp_test_client::error_callback | ( | const boost::system::error_code & | ec, |
| const std::string & | str | ||
| ) | [inline, private] |
Definition at line 198 of file stomp_test_client.cpp.


| std::string stomp_test_client::get_prompt | ( | ) | const [inline] |
Definition at line 91 of file stomp_test_client.cpp.
| bool stomp_test_client::handle_command | ( | std::string & | rv, |
| const std::string & | cmd, | ||
| const std::string & | args | ||
| ) | [inline] |
| bool stomp_test_client::init | ( | int | argc, |
| char * | argv[] | ||
| ) | [inline, private] |
Definition at line 160 of file stomp_test_client.cpp.


| void stomp_test_client::message_callback | ( | const std::string & | topic, |
| const std::string & | msg | ||
| ) | [inline, private] |
Definition at line 203 of file stomp_test_client.cpp.


| void stomp_test_client::num_pending | ( | const std::vector< std::string > & | args, |
| std::ostream & | os | ||
| ) | [inline, private] |
Definition at line 382 of file stomp_test_client.cpp.


| void stomp_test_client::num_processed | ( | const std::vector< std::string > & | args, |
| std::ostream & | os | ||
| ) | [inline, private] |
Definition at line 374 of file stomp_test_client.cpp.


| void stomp_test_client::parse_options | ( | const std::vector< std::string > & | args, |
| const po::options_description & | od, | ||
| const po::positional_options_description & | pd, | ||
| po::variables_map & | vm | ||
| ) | [inline, private] |
| void stomp_test_client::process | ( | ) | [inline, private] |
Definition at line 409 of file stomp_test_client.cpp.


| void stomp_test_client::reset | ( | const std::vector< std::string > & | args, |
| std::ostream & | os | ||
| ) | [inline, private] |
Definition at line 360 of file stomp_test_client.cpp.


| void stomp_test_client::reset_client | ( | ) | [inline, private] |
| int stomp_test_client::run | ( | int | argc, |
| char * | argv[] | ||
| ) | [inline] |
Definition at line 64 of file stomp_test_client.cpp.


| bool stomp_test_client::run_command | ( | cmd_method_t | meth, |
| std::string & | rv, | ||
| const std::vector< std::string > & | av, | ||
| std::ostream & | os | ||
| ) | [inline, private] |
| void stomp_test_client::send | ( | const std::vector< std::string > & | args, |
| std::ostream & | os | ||
| ) | [inline, private] |
Definition at line 326 of file stomp_test_client.cpp.


| std::string stomp_test_client::show_help | ( | ) | const [inline] |
| void stomp_test_client::show_help | ( | po::options_description & | opt | ) | const [inline, private] |
| void stomp_test_client::simple_command | ( | const std::string & | name, |
| Func | func, | ||
| const std::vector< std::string > & | args, | ||
| std::ostream & | os | ||
| ) | [inline, private] |
Definition at line 231 of file stomp_test_client.cpp.


| bool stomp_test_client::simple_command_help | ( | const std::string & | name, |
| const std::vector< std::string > & | args, | ||
| std::ostream & | os | ||
| ) | [inline, private] |
Definition at line 208 of file stomp_test_client.cpp.


| void stomp_test_client::status | ( | const std::vector< std::string > & | args, |
| std::ostream & | os | ||
| ) | [inline, private] |
Definition at line 365 of file stomp_test_client.cpp.


| void stomp_test_client::subscribe | ( | const std::vector< std::string > & | args, |
| std::ostream & | os | ||
| ) | [inline, private] |
Definition at line 267 of file stomp_test_client.cpp.


| void stomp_test_client::unsubscribe | ( | const std::vector< std::string > & | args, |
| std::ostream & | os | ||
| ) | [inline, private] |
Definition at line 300 of file stomp_test_client.cpp.


boost::shared_ptr<moost::mq::stomp_client> stomp_test_client::m_client [private] |
Definition at line 148 of file stomp_test_client.cpp.
size_t stomp_test_client::m_consumer_pool_size [private] |
Definition at line 142 of file stomp_test_client.cpp.
std::string stomp_test_client::m_default_log_level [private] |
Definition at line 145 of file stomp_test_client.cpp.
float stomp_test_client::m_keepalive_interval [private] |
Definition at line 143 of file stomp_test_client.cpp.
std::string stomp_test_client::m_logging_config [private] |
Definition at line 146 of file stomp_test_client.cpp.
float stomp_test_client::m_reconnect_interval [private] |
Definition at line 144 of file stomp_test_client.cpp.