- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 366 for publisher (0.08 seconds)
-
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java
import org.codehaus.plexus.logging.Logger; import org.eclipse.aether.ConfigurationProperties; import org.eclipse.aether.util.ConfigUtils; // TODO remove the update check manager // TODO separate into retriever and publisher // TODO remove hardcoding of checksum logic /** * Manages <a href="https://maven.apache.org/wagon">Wagon</a> related operations in Maven. */ @Named @Singleton @Deprecated
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Sat Apr 05 11:52:05 GMT 2025 - 29.9K bytes - Click Count (0) -
internal/event/target/amqp.go
return err } if err = ch.Publish(target.args.Exchange, target.args.RoutingKey, target.args.Mandatory, target.args.Immediate, amqp091.Publishing{ Headers: headers, ContentType: "application/json", DeliveryMode: target.args.DeliveryMode, Body: data, }); err != nil { return err } // check for publisher confirms only if its enabledCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 21 04:25:07 GMT 2025 - 10K bytes - Click Count (0) -
internal/config/notify/help.go
config.HelpKV{ Key: target.NATSStreamingAsync, Description: "[DEPRECATED] set to 'on', to enable asynchronous publish", Optional: true, Type: "on|off", }, config.HelpKV{ Key: target.NATSStreamingMaxPubAcksInFlight, Description: "[DEPRECATED] number of messages to publish without waiting for ACKs", Optional: true, Type: "number", }, config.HelpKV{Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 19.2K bytes - Click Count (0) -
internal/grid/manager.go
ctx: ctx, id: m.ID, local: o.Local, remote: host, handlers: &m.handlers, blockConnect: o.BlockConnect, publisher: o.TraceTo, incomingBytes: o.Incoming, outgoingBytes: o.Outgoing, dialer: o.Dialer, authFn: o.AuthFn, }) } if !found {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Nov 12 20:41:41 GMT 2024 - 10.8K bytes - Click Count (0) -
internal/grid/connection.go
c.baseFlags |= FlagCRCxxh3 } if !strings.HasPrefix(o.local, "https://") && !strings.HasPrefix(o.local, "wss://") { c.baseFlags |= FlagCRCxxh3 } if o.publisher != nil { c.traceRequests(o.publisher) } if o.local == o.remote { panic("equal hosts") } if c.shouldConnect() { c.side = ws.StateClientSide go func() { if o.blockConnect != nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 46.9K bytes - Click Count (0) -
build-tools-internal/src/integTest/groovy/org/elasticsearch/gradle/internal/PublishPluginFuncTest.groovy
<!-- This module was also published with a richer model, Gradle metadata, --> <!-- which should be used instead. Do not delete the following line which --> <!-- is to indicate to Gradle or any Gradle module metadata file consumer --> <!-- that they should prefer consuming it instead. --> <!-- do_not_remove: published-with-gradle-metadata --> <modelVersion>4.0.0</modelVersion>
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 22 07:24:59 GMT 2021 - 19K bytes - Click Count (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/AbstractGradleViolationRule.groovy
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Thu Jan 22 12:18:18 GMT 2026 - 10K bytes - Click Count (0) -
android/guava/pom.xml
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> <!-- do_not_remove: published-with-gradle-metadata --> <modelVersion>4.0.0</modelVersion> <parent> <groupId>com.google.guava</groupId> <artifactId>guava-parent</artifactId> <version>999.0.0-HEAD-android-SNAPSHOT</version> </parent>
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Nov 17 21:36:50 GMT 2025 - 9.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/CoordinatorHelper.java
/** * Publishes an event to all instances. * * @param eventName the event name. * @param data optional event data. */ public void publishEvent(final String eventName, final String data) { publishEvent(eventName, TARGET_ALL, data); } /** * Publishes an event to a specific instance or all instances. *Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 33.3K bytes - Click Count (0) -
cmd/config-current.go
Description: "publish bucket notifications to webhook endpoints", MultipleTargets: true, }, config.HelpKV{ Key: config.NotifyAMQPSubSys, Description: "publish bucket notifications to AMQP endpoints", MultipleTargets: true, }, config.HelpKV{ Key: config.NotifyKafkaSubSys, Description: "publish bucket notifications to Kafka endpoints",
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 28.5K bytes - Click Count (0)