Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for addBroken (0.2 sec)

  1. testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/HttpServer.groovy

                        afterHandle.execute(request)
                    }
                }
            }
        }
    
        /**
         * Adds a broken resource at the given URL.
         */
        void addBroken(String path) {
            allow(path, true, null, broken())
        }
    
        /**
         * Expects one GET request, which fails with a 500 status code
         */
        void expectGetBroken(String path) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 32.3K bytes
    - Viewed (0)
  2. internal/event/target/mqtt.go

    		SetUsername(args.User).
    		SetPassword(args.Password).
    		SetMaxReconnectInterval(args.MaxReconnectInterval).
    		SetKeepAlive(args.KeepAlive).
    		SetTLSConfig(&tls.Config{RootCAs: args.RootCAs}).
    		AddBroker(args.Broker.String())
    
    	target.client = mqtt.NewClient(options)
    
    	token := target.client.Connect()
    	ok := token.WaitTimeout(reconnectInterval)
    	if !ok {
    		return store.ErrNotConnected
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.2K bytes
    - Viewed (0)
Back to top