private void notifyAtListner(final Subscriber<?, ?> listener, final Envelop data) {
        executor.execute(new Runnable() {
            @Override
            public void run() {
                
                final Filter f = listener.getFilter();
                if (f.getManagedType() == null || data.getContentType().isAssignableFrom(f.getManagedType())) {
                    Serializable content = data.getContent();
                    if (f.passes(content)) {
                        listener.handle(data);
                    }
                }
               
            }
        });
    }