Method stop_thread

lib_acl_cpp/src/redis/redis_client_pipeline.cpp:128–135

}

void redis_pipeline_channel::stop_thread()
{
	redis_pipeline_message *message = NEW
		redis_pipeline_message(redis_pipeline_t_stop, NULL);
	push(message);
	this->wait(); // Call the base class thread::wait().
	message->unrefer();
}

void redis_pipeline_channel::push(redis_pipeline_message* msg) const
{