crawlingInfo = new CrawlingInfo();
                        crawlingInfo.setSessionId(list.get(0));
                        crawlingInfo.setCreatedTime(formatter.parse(list.get(1)).getTime());
                        crawlingInfoBhv.insert(crawlingInfo, op -> op.setRefreshPolicy(Constants.TRUE));
                    }

                    final CrawlingInfoParam entity = new CrawlingInfoParam();

        Date expires = crawlingInfoHelper.getDocumentExpires(null);
        assertNotNull(expires); // Returns documentExpires when config is null
        assertEquals(currentTime + 1000, expires.getTime());

        // Test when documentExpires is set but config is provided (but config has no timeToLive)
        crawlingInfoHelper.documentExpires = currentTime + 5000;

  }

  public void testSimpleRateUpdate() {
    RateLimiter limiter = RateLimiter.create(5.0, 5, SECONDS);
    assertThat(limiter.getRate()).isEqualTo(5.0);
    limiter.setRate(10.0);
    assertThat(limiter.getRate()).isEqualTo(10.0);

    assertThrows(IllegalArgumentException.class, () -> limiter.setRate(0.0));
    assertThrows(IllegalArgumentException.class, () -> limiter.setRate(-10.0));

  }

  public void testSimpleRateUpdate() {
    RateLimiter limiter = RateLimiter.create(5.0, 5, SECONDS);
    assertThat(limiter.getRate()).isEqualTo(5.0);
    limiter.setRate(10.0);
    assertThat(limiter.getRate()).isEqualTo(10.0);

    assertThrows(IllegalArgumentException.class, () -> limiter.setRate(0.0));
    assertThrows(IllegalArgumentException.class, () -> limiter.setRate(-10.0));

rstChild),a=b.offsetWidth,f?k.removeChild(c):c.removeChild(b),k.style.fontSize=d,e&&(c.style.fontSize=e),a=i=parseFloat(a)},u=function(b){var c="clientWidth",d=k[c],e="CSS1Compat"===j.compatMode&&d||j.body[c]||d,f={},o=s[s.length-1],r=(new Date).getTime();if(b&&g&&p>r-g)return a.clearTimeout(h),h=a.setTimeout(u,p),void 0;g=r;for(var v in l)if(l.hasOwnProperty(v)){var w=l[v],x=w.minw,y=w.maxw,z=null===x,A=null===y,B="em";x&&(x=parseFloat(x)*(x.indexOf(B)>-1?i||t():1)),y&&(y=parseFloat(y)*(y.index...

    }

    /**
     * Release a send region back to the pool
     *
     * @param region memory region to release
     */
    public void releaseSendRegion(RdmaMemoryRegion region) {
        if (region.getSize() == sendBufferSize && availableSendRegions.size() < initialSendBuffers * 2) {
            availableSendRegions.offer(region);
        } else {
            region.close();
            totalReleased.incrementAndGet();

        int count = 0;
        String scrollId = response.getScrollId();
        try {
            while (scrollId != null) {
                final SearchHits searchHits = response.getHits();
                final SearchHit[] hits = searchHits.getHits();
                if (hits.length == 0) {
                    break;
                }

                final BulkRequestBuilder bulkRequest = client.prepareBulk();

        return new IntervalControlHelper() {
            @Override
            protected Calendar getCurrentCal() {
                final Calendar cal = Calendar.getInstance();
                cal.setTimeInMillis(date.getTime());
                cal.set(Calendar.DAY_OF_WEEK, day);
                return cal;
            }
        };
    }

    public void test_checkCrawlerStatus() throws InterruptedException {

    @Override
    public String getType() {
        return type;
    }

    @Override
    public void setFile(File file) {
        this.file = file;
    }

    @Override
    public File getFile() {
        return file;
    }

    @Override
    public ArtifactRepository getRepository() {
        return repository;
    }

    @Override

    }

    @Override
    public long getExpiration() {
        handshake();
        return this.connection.getExpiration();
    }

    @Override
    public long getDate() {
        handshake();
        return this.connection.getDate();
    }

    @Override
    public long getLastModified() {
        handshake();
        return this.connection.getLastModified();
    }

    @Override