#include "acl_cpp/lib_acl.hpp"
int main(int argc, char * argv[])
{
acl::acl_cpp_init();
acl::log::stdout_open(true);
acl::string redis_addr("127.0.0.1:6379");
int conn_timeout = 10, rw_timeout = 10;
acl::redis_client client(redis_addr, conn_timeout, rw_timeout);
acl::redis_pubsub redis;
redis.set_client(&client);
redis.clear();
acl::string channel = "md";
redis.subscribe(channel,NULL);
acl::string msg;
channel.clear();
msg.clear();
redis.clear();
while(true){
if ((redis.get_message(channel, msg)) == false)
{
printf("get_message error(%s)\r\n",
redis.result_error());
//return false;
}
else
{
printf("message: %s, channel: %s\r\n",
msg.c_str(), channel.c_str());
}
}
return 0;
}