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;
	}
}

@@ -308,14 +308,20 @@
 %7B%0A%09%09
-return
+event = null
 ;%0A%09%7D

set event to null