Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 2 of 2 for WaitTimeout (0.07 seconds)

  1. src/main/java/org/codelibs/fess/llm/AbstractLlmClient.java

            }
            try {
                if (!concurrencyLimiter.tryAcquire(getConcurrencyWaitTimeoutMs(), TimeUnit.MILLISECONDS)) {
                    logger.warn("[LLM] Concurrency limit exceeded. name={}, maxConcurrent={}, waitTimeout={}ms", getName(),
                            getMaxConcurrentRequests(), getConcurrencyWaitTimeoutMs());
                    throw new LlmException("Too many concurrent requests", LlmException.ERROR_RATE_LIMIT);
                }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 21 06:04:58 GMT 2026
    - 72K bytes
    - Click Count (0)
  2. internal/event/target/mqtt.go

    	if err != nil {
    		return err
    	}
    
    	token := target.client.Publish(target.args.Topic, target.args.QoS, false, string(data))
    	if !token.WaitTimeout(reconnectInterval) {
    		return store.ErrNotConnected
    	}
    	return token.Error()
    }
    
    // SendFromStore - reads an event from store and sends it to MQTT.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.2K bytes
    - Click Count (0)
Back to Top