private ConsumerMessageFilter getFilter0(FutureTask<ConsumerMessageFilter> task) {
        try {
            return task.get();
        }
        catch (ExecutionException e) {
            throw ThreadUtils.launderThrowable(e.getCause());
        }
        catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return null;
        }
    }
Consumer filter manager.

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