protected int queueReplicas = 1;

    protected int dataReplicas = 1;

    protected int filterReplicas = 1;

    public String getQueueIndex() {
        return queueIndex;
    }

    public void setQueueIndex(final String queueIndex) {
        this.queueIndex = queueIndex;
    }

    public String getDataIndex() {
        return dataIndex;

    protected int pollingFetchSize = 1000;

    protected int maxCrawlingQueueSize = 100;

    public OpenSearchUrlQueueService(final OpenSearchCrawlerConfig crawlerConfig) {
        index = crawlerConfig.getQueueIndex();
        setNumberOfShards(crawlerConfig.getQueueShards());
        setNumberOfReplicas(crawlerConfig.getQueueReplicas());
    }

    public OpenSearchUrlQueueService(final String name, final String type) {