Method get_pending_message

lib_acl_cpp/src/redis/redis_stream.cpp:1007–1050

}

bool redis_stream::get_pending_message(const redis_result& rr,
	redis_pending_message& message)
{
	if (rr.get_type() != REDIS_RESULT_ARRAY) {
		return false;
	}

	size_t size;
	const redis_result** children = rr.get_children(&size);
	if (children == NULL || size < 4) {
		return false;
	}

	const redis_result* child = children[0];
	if (child->get_type() != REDIS_RESULT_STRING) {
		return false;
	}
	child->argv_to_string(message.id);

	child = children[1];
	if (child->get_type() != REDIS_RESULT_STRING) {
		return false;
	}
	child->argv_to_string(message.consumer);

	child = children[2];
	if (child->get_type() != REDIS_RESULT_INTEGER) {
		return false;
	}
	bool success;
	long long n = child->get_integer64(&success);
	if (n < 0 || !success) {
		return false;
	}
	message.elapsed = (unsigned long long) n;

	n = child->get_integer(&success);
	if (n < 0 || !success) {
		return false;
	}
	message.delivered = (size_t) n;

	return true;
}

//////////////////////////////////////////////////////////////////////////////