package com.agent.xml;

import com.framework.util.PropertiesLoader;
import org.apache.commons.lang3.StringUtils;

import redis.clients.jedis.Jedis;

/**
 * 
 * Depiction: 发送报文
 * <p>
 * Modify:
 * <p>
 * Author: William Lynn
 * <p>
 * Create Date：2018年7月16日 下午12:13:37
 *
 */
class XmlSendTask extends Thread {
	// 创建 缓存服务器的地址ip
//	private Jedis jedis = new Jedis("10.50.3.71", 6379);
//	private Jedis jedis = new Jedis("10.50.3.84", 6379);
	private Jedis jedis = new Jedis(PropertiesLoader.getRedis("host"),
			Integer.valueOf(PropertiesLoader.getRedis("port")));
	private String xml;

	public XmlSendTask(String xml) {
		this.xml = xml;
	}

	@Override
	public void run() {
		long flag = -1;
		if (!StringUtils.isEmpty(xml)) {
			xml = xml.replaceAll("[\\u0000-\\u001f]", "");
			flag = jedis.lpush("task-queue", xml);
		}

		System.err.println("redis result -->" + flag);
	}

	public void send() {
		this.start();
	}

}