Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for routingKey (0.2 sec)

  1. internal/event/target/amqp.go

    )
    
    // AMQPArgs - AMQP target arguments.
    type AMQPArgs struct {
    	Enable            bool     `json:"enable"`
    	URL               xnet.URL `json:"url"`
    	Exchange          string   `json:"exchange"`
    	RoutingKey        string   `json:"routingKey"`
    	ExchangeType      string   `json:"exchangeType"`
    	DeliveryMode      uint8    `json:"deliveryMode"`
    	Mandatory         bool     `json:"mandatory"`
    	Immediate         bool     `json:"immediate"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. internal/config/notify/legacy.go

    			Key:   target.AmqpURL,
    			Value: cfg.URL.String(),
    		},
    		config.KV{
    			Key:   target.AmqpExchange,
    			Value: cfg.Exchange,
    		},
    		config.KV{
    			Key:   target.AmqpRoutingKey,
    			Value: cfg.RoutingKey,
    		},
    		config.KV{
    			Key:   target.AmqpExchangeType,
    			Value: cfg.ExchangeType,
    		},
    		config.KV{
    			Key:   target.AmqpDeliveryMode,
    			Value: strconv.Itoa(int(cfg.DeliveryMode)),
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 04:37:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  3. internal/config/notify/parse.go

    			return nil, err
    		}
    		amqpArgs := target.AMQPArgs{
    			Enable:            enabled,
    			URL:               *url,
    			Exchange:          env.Get(exchangeEnv, kv.Get(target.AmqpExchange)),
    			RoutingKey:        env.Get(routingKeyEnv, kv.Get(target.AmqpRoutingKey)),
    			ExchangeType:      env.Get(exchangeTypeEnv, kv.Get(target.AmqpExchangeType)),
    			DeliveryMode:      uint8(deliveryMode),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  4. docs/bucket/notifications/README.md

    ARGS:
    url*           (url)       AMQP server endpoint e.g. `amqp://myuser:mypassword@localhost:5672`
    exchange       (string)    name of the AMQP exchange
    exchange_type  (string)    AMQP exchange type
    routing_key    (string)    routing key for publishing
    mandatory      (on|off)    quietly ignore undelivered messages when set to 'off', default is 'on'
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  5. cmd/testdata/undeleteable-object.tgz

    k{"key":"batch_size","value":"1"},{"key":"queue_size","value":"100000"},{"key":"queue_dir","value":""}]},"notify_amqp":{"_":[{"key":"enable","value":"off"},{"key":"url","value":""},{"key":"exchange","value":""},{"key":"exchange_type","value":""},{"key":"routing_key","value":""},{"key":"mandatory","value":"off"},{"key":"durable","value":"off"},{"key":"no_wait","value":"off"},{"key":"internal","value":"off"},{"key":"auto_deleted","value":"off"},{"key":"delivery_mode","value":"0"},{"key":"publisher_confirms"...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 26 00:31:12 UTC 2024
    - 8.7M bytes
    - Viewed (0)
Back to top