}

    public EsUrlFilterService(final String name, final String type) {
        this.index = name + "." + type;
    }

    @PostConstruct
    public void init() {
        fesenClient.addOnConnectListener(() -> createMapping("filter"));

        includeFilterCache = createFilterCache(INCLUDE);
        excludeFilterCache = createFilterCache(EXCLUDE);
    }

    }

    public EsDataService(final String name, final String type) {
        this.index = name + "." + type;
    }

    @PostConstruct
    public void init() {
        fesenClient.addOnConnectListener(() -> createMapping("data"));
    }

    @Override
    public void store(final EsAccessResult accessResult) {
        super.insert(accessResult, accessResult.getId() == null ? OpType.CREATE : OpType.INDEX);
    }

    }

    public EsUrlQueueService(final String name, final String type) {
        this.index = name + "." + type;
    }

    @PostConstruct
    public void init() {
        fesenClient.addOnConnectListener(() -> createMapping("queue"));
    }

    @PreDestroy
    public void destroy() {
        sessionCache.entrySet().stream().map(e -> e.getValue().waitingQueue).forEach(q -> q.forEach(urlQueue -> {
            try {

        }
    }

    public void setAddress(final String address) {
        this.address = address;
    }

    public void addOnConnectListener(final OnConnectListener listener) {
        onConnectListenerList.add(listener);
    }

    public boolean connected() {
        return connected;
    }

    public void connect() {