Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 366 for publisher (0.08 seconds)

  1. 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)
  2. 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 enabled
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 21 04:25:07 GMT 2025
    - 10K bytes
    - Click Count (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/AbstractGradleViolationRule.groovy

                        <span class="btn btn-info" role="button">Update baseline</span>
                      </summary>
                      <div class="well">
                        Sometimes, the change was made on the `release` branch but hasn't yet been published to the baseline version.
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Jan 22 12:18:18 GMT 2026
    - 10K bytes
    - Click Count (0)
  8. 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)
  9. 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)
  10. 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)
Back to Top