@SuppressWarnings("unchecked")
    private ConsumerMessageFilter intanceFilter(String className) throws Exception {
        Class<ConsumerMessageFilter> clazz =
                (Class<ConsumerMessageFilter>) Class.forName(className, true, this.filterClassLoader);
        if (clazz != null) {
            return clazz.newInstance();
        }
        else {
            return null;
        }
    }
Consumer filter manager.

@author dennis<killme2008@gmail.com>
metamorphosis-server/src/main/java/com/taobao/metamorphosis/server/filter/ConsumerFilterManager.java