if (dataMap.remove(getParamValue(paramMap, "field.max_depth", "max_depth")) instanceof final String maxDepth
                && StringUtil.isNotBlank(maxDepth)) {
            try {
                return Integer.parseInt(maxDepth);
            } catch (final NumberFormatException e) {
                if (logger.isDebugEnabled()) {
                    logger.warn("Failed to parse max_depth: '{}'. Expected: integer value", maxDepth, e);

        assertFalse(result);
    }

    /**
     * Test isValid method with depth exceeding maxDepth.
     */
    public void test_isValid_exceedsMaxDepth() throws Exception {
        final UrlQueue<?> urlQueue = new UrlQueueImpl<>();
        urlQueue.setUrl("http://example.com/");
        urlQueue.setDepth(5); // Exceeds maxDepth of 3

        when(urlFilter.match(anyString())).thenReturn(true);

        crawlerContext.maxThreadCheckCount = maxThreadCheckCount;
    }

    /**
     * Sets the maximum depth.
     * @param maxDepth The maximum depth.
     */
    public void setMaxDepth(final int maxDepth) {
        crawlerContext.maxDepth = maxDepth;
    }

    /**
     * Sets the maximum access count.
     * @param maxAccessCount The maximum access count.
     */

// Err returns the most recent decoder error if any, or nil
func (d *Decoder) Err() error { return d.err }

// MaxDepth will set the maximum recursion depth.
// If the maximum depth is exceeded, ErrMaxDepth is returned.
// Less than or 0 means no limit (default).
func (d *Decoder) MaxDepth(n int) *Decoder {
	d.maxDepth = n
	return d
}

// Decode parses the JSON-encoded data and returns an interface value

// keys, so we need to use this technique to merge the
// keys.
func sanitizePolicy(r io.Reader) (io.Reader, error) {
	var buf bytes.Buffer
	e := json.NewEncoder(&buf)
	d := jstream.NewDecoder(r, 0).ObjectAsKVS().MaxDepth(10)
	sset := set.NewStringSet()
	for mv := range d.Stream() {
		if mv.ValueType == jstream.Object {
			// This is a JSON object type (that preserves key order)
			kvs, ok := mv.Value.(jstream.KVS)
			if ok {

```java
String sessionId                // Format: yyyyMMddHHmmssSSS
volatile CrawlerStatus status   // DONE, RUNNING
AtomicLong accessCount          // Thread-safe counter
int numOfThread = 10            // Crawler threads
int maxDepth = -1               // Max depth (-1 = unlimited)
long maxAccessCount = 0         // Max URLs (0 = unlimited)
```

### CrawlerThread (`CrawlerThread.java`)

Worker thread for crawling.

        crawlerContext.setMaxThreadCheckCount(Integer.MAX_VALUE);
        assertEquals(Integer.MAX_VALUE, crawlerContext.getMaxThreadCheckCount());
    }

    /**
     * Test maxDepth getter and setter
     */
    public void test_maxDepth() {
        assertEquals(-1, crawlerContext.getMaxDepth());

        crawlerContext.setMaxDepth(5);
        assertEquals(5, crawlerContext.getMaxDepth());