package com.iplatform.tcp.util.ws;

import java.util.concurrent.TimeUnit;

import com.walker.tcp.Context;
import com.walker.tcp.filter.DefaultFilter;

/**
 * 让接收数据有规律间隔的，过滤器实现
 * @author Administrator
 *
 */
public class StepTimeFilter extends DefaultFilter {

	@Override
	public boolean  doFilter(Context context) throws Exception {
//		long spanTime = context.getPreviousTimeSpan();
//		if(context.getPreviousData() != null && spanTime != 0){
//			long span = Math.abs(spanTime - 600);
//			TimeUnit.MILLISECONDS.sleep(span);
//			logger.debug("~~~~~~~~~~~~~~过滤器执行一次，间隔：" + span + ", spanTime = " + spanTime);
//			logger.debug(context.getPreviousData());
//		} else {
//			TimeUnit.MILLISECONDS.sleep(600);
//			logger.debug("~~~~~~~~~~~~~~过滤器执行一次，间隔：600 mills" );
//		}

		TimeUnit.MILLISECONDS.sleep(500);
		return true;
	}

}