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.