package org.ctrip.ops.sysdev.filters;

import java.util.Map;
import java.util.concurrent.ArrayBlockingQueue;

public class Drop extends BaseFilter {
	public Drop(Map config, ArrayBlockingQueue inputQueue) {
		super(config, inputQueue);
	}

	protected void prepare() {
	};

	protected void filter(Map event) {
		return;
	}
}

package org.ctrip.ops.sysdev.filters;

import java.util.Map;
import java.util.concurrent.ArrayBlockingQueue;

public class Drop extends BaseFilter {
	public Drop(Map config, ArrayBlockingQueue inputQueue) {
		super(config, inputQueue);
	}

	protected void prepare() {
	};

	protected void filter(Map event) {
		event = null;
	}
}

set event to null