Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 52 for amqp (0.2 seconds)

  1. internal/config/notify/parse.go

    		}
    		if err = esArgs.Validate(); err != nil {
    			return nil, err
    		}
    		esTargets[k] = esArgs
    	}
    	return esTargets, nil
    }
    
    // DefaultAMQPKVS - default KV for AMQP config
    var (
    	DefaultAMQPKVS = config.KVS{
    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOff,
    		},
    		config.KV{
    			Key:   target.AmqpURL,
    			Value: "",
    		},
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  2. 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",
    			MultipleTargets: true,
    		},
    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)
  3. cmd/config-migrate.go

    	}
    
    	xldap.SetIdentityLDAP(newCfg, cfg.LDAPServerConfig)
    	opa.SetPolicyOPAConfig(newCfg, cfg.Policy.OPA)
    	compress.SetCompressionConfig(newCfg, cfg.Compression)
    
    	for k, args := range cfg.Notify.AMQP {
    		notify.SetNotifyAMQP(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.Elasticsearch {
    		notify.SetNotifyES(newCfg, k, args)
    	}
    	for k, args := range cfg.Notify.Kafka {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  4. cmd/server_test.go

    	// generate a random bucket Name.
    	bucketName := getRandomBucketName()
    	// HTTP request to create the bucket.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 118.1K bytes
    - Click Count (0)
  5. compat/maven-model-builder/src/test/resources/dag.txt

    	quarkus/test-framework/security/pom.xml
    	quarkus/extensions/oidc/runtime/pom.xml
    quarkus/extensions/smallrye-reactive-messaging-amqp/deployment/pom.xml
    	quarkus/core/deployment/pom.xml
    	quarkus/extensions/smallrye-reactive-messaging/deployment/pom.xml
    	quarkus/extensions/smallrye-reactive-messaging-amqp/runtime/pom.xml
    	quarkus/extensions/reactive-streams-operators/mutiny-reactive-streams-operators/deployment/pom.xml
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 224K bytes
    - Click Count (0)
  6. .idea/scopes/Gradle_public_API.xml

        <scope name="Gradle public API"
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Jul 18 15:08:47 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  7. src/main/webapp/WEB-INF/view/admin/searchlog/admin_searchlog_details.jsp

                                                        <td><la:link
                                                                href="/admin/searchlog/search?logType=search&amp;queryId=${f:u(info.value)}&amp;userSessionId=&amp;requestedTimeRange=&amp;accessType=">${f:h(info.value)}</la:link></td>
                                                    </c:when>
                                                    <c:when test="${info.key == 'User Info ID'}">
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Feb 23 08:03:44 GMT 2026
    - 10.1K bytes
    - Click Count (0)
  8. src/test/java/org/codelibs/core/collection/ArrayMapTest.java

         * @throws Exception
         */
        @Test
        public void testPerformance() throws Exception {
            int num = 100000;
            Map<String, Object> hmap = new HashMap<String, Object>();
            Map<String, Object> amap = new ArrayMap<String, Object>();
    
            long start = System.currentTimeMillis();
            for (int i = 0; i < num; i++) {
                hmap.put(String.valueOf(i), null);
            }
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Sat May 10 01:32:17 GMT 2025
    - 10.7K bytes
    - Click Count (0)
  9. src/main/webapp/js/admin/plugins/form-validator/sanitize.js

    c:"\\"+c,"g");b=b.replace(d,"")}),b},escape:function(b,c){var d=c.valAttr("is-escaped"),e={"<":"__%AMP%__lt;",">":"__%AMP%__gt;","&":"__%AMP%__amp;","'":"__%AMP%__#8217;",'"':"__%AMP%__quot;"};return"yes"===d?b:(c.valAttr("is-escaped","yes"),c.one("keyup",function(a){9!==a.keyCode&&c.valAttr("is-escaped","no")}),a.each(e,function(a,c){b=b.replace(new RegExp(a,"g"),c)}),b.replace(new RegExp("__%AMP%__","g"),"&"))}},e=function(b,e,f){e||(e=a("form")),e.each||(e=a(e));var g=function(){var b=a(this)...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Jan 01 05:12:47 GMT 2018
    - 2.7K bytes
    - Click Count (0)
  10. .junit.run/Not Slow.run.xml

        <option name="PARAMETERS" value="" />
        <option name="TEST_SEARCH_SCOPE">
          <value defaultName="wholeProject" />
        </option>
        <tag value="!Slow &amp; !Slowish &amp; !Remote &amp; !Android" />
        <method v="2">
          <option name="Make" enabled="true" />
        </method>
      </configuration>
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Nov 21 13:28:45 GMT 2020
    - 730 bytes
    - Click Count (0)
Back to Top