- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 230 for _producer (0.29 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp-testing-support/src/main/kotlin/okhttp3/JsseDebugLogging.kt
message.startsWith("Reload ") -> Type.Setup message == "No session to resume." -> Type.Handshake message.startsWith("Consuming ") -> Type.Handshake message.startsWith("Produced ") -> Type.Handshake message.startsWith("Negotiated ") -> Type.Handshake message.startsWith("Found resumable session") -> Type.Handshake message.startsWith("Resuming session") -> Type.Handshake
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 2.8K bytes - Click Count (0) -
internal/config/notify/legacy.go
config.KV{ Key: target.KafkaSASLPassword, Value: cfg.SASL.Password, }, config.KV{ Key: target.KafkaCompressionCodec, Value: cfg.Producer.Compression, }, config.KV{ Key: target.KafkaCompressionLevel, Value: strconv.Itoa(cfg.Producer.CompressionLevel), }, } return nil } // SetNotifyAMQP - helper for config migration from older config.Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Apr 27 04:30:57 GMT 2025 - 13.3K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/EmptyImmutableListMultimap.java
private EmptyImmutableListMultimap() { super(ImmutableMap.of(), 0); } /* * TODO(b/242884182): Figure out why this helps produce the same class file when we compile most * of common.collect a second time with the results of the first compilation on the classpath. Or * just back this out once we stop doing that (which we'll do after our internal GWT setup
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 22 21:07:18 GMT 2025 - 1.8K bytes - Click Count (0) -
guava/src/com/google/common/collect/EmptyImmutableListMultimap.java
private EmptyImmutableListMultimap() { super(ImmutableMap.of(), 0); } /* * TODO(b/242884182): Figure out why this helps produce the same class file when we compile most * of common.collect a second time with the results of the first compilation on the classpath. Or * just back this out once we stop doing that (which we'll do after our internal GWT setup
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 22 21:07:18 GMT 2025 - 1.8K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/EmptyImmutableSetMultimap.java
private EmptyImmutableSetMultimap() { super(ImmutableMap.of(), 0, null); } /* * TODO(b/242884182): Figure out why this helps produce the same class file when we compile most * of common.collect a second time with the results of the first compilation on the classpath. Or * just back this out once we stop doing that (which we'll do after our internal GWT setup
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 22 21:07:18 GMT 2025 - 1.8K bytes - Click Count (0) -
.gitignore
/www/master/shared/config/development.json # Karma output /www/test_out # precommit temporary directories created by ./hack/verify-generated-docs.sh and ./hack/lib/util.sh /_tmp/ /doc_tmp/ # Test artifacts produced by Prow/kubetest2 jobs /_artifacts/ /_rundir/ # Go dependencies installed on Jenkins /_gopath/ # Config directories created by gcloud and gsutil on Jenkins /.config/gcloud*/ /.gsutil/
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Tue Mar 17 02:28:41 GMT 2026 - 2.2K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/ModelBuilder.java
*/ ModelBuildingResult build(ModelBuildingRequest request) throws ModelBuildingException; /** * Builds the effective model by completing the specified interim result which was produced by a previous call to * {@link #build(ModelBuildingRequest)} with {@link ModelBuildingRequest#isTwoPhaseBuilding()} being {@code true}.Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Feb 25 08:27:34 GMT 2025 - 2.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/suggest/entity/SuggestItemBoundaryTest.java
SuggestItem item2 = new SuggestItem(text2, readings2, null, 0L, 0L, 1.0f, null, null, null, SuggestItem.Kind.QUERY); // Different word order should produce different IDs (since text is "word1 word2" vs "word2 word1") assertFalse("Different word order should produce different IDs", item1.getId().equals(item2.getId())); }
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sat Jan 17 05:10:37 GMT 2026 - 22.2K bytes - Click Count (0) -
cycle_suppress_list.txt
FIELD com.google.common.util.concurrent.AbstractFuture.Listener.executor com.google.common.util.concurrent.ExecutionSequencer.TaskNonReentrantExecutor # ***** FALSE POSITIVES ***** # The Runnable type is so generic that it produces too many false positives. TYPE java.lang.Runnable FIELD com.google.common.base.Converter.reverse
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 24 01:59:49 GMT 2025 - 3.2K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* inserted by producers and extracted by consumers. Once created, the capacity cannot be increased. * Attempts to {@code put} an element into a full queue will result in the operation blocking; * attempts to {@code take} an element from an empty queue will similarly block. * * <p>This class supports an optional fairness policy for ordering waiting producer and consumerCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 22.4K bytes - Click Count (0)