INNER CODE UNIT · Go

MCallTimeout

moleculer-go/moleculer · broker/broker_internals_test.go:419

			MCallTimeout := 20 * time.Second
			actionHandler := func(result string) func(moleculer.Context, moleculer.Payload) interface{} {
				return func(ctx moleculer.Context, param moleculer.Payload) interface{} {
					result := fmt.Sprint("input: (", param.String(), " ) -> output: ( ", result, " )")
					//fmt.Println("MCALL Action --> ", result)
					return result
				}
			}
			logLevel := "FATAL"
			mem := &memory.SharedMemory{}
			bkr1 := New(
				&moleculer.Config{
					MCallTimeout:   MCallTimeout,
					LogLevel:       logLevel,
					DiscoverNodeID: func() string { return "test-broker1" },
					TransporterFactory: func() interface{} {
						transport := memory.Create(log.WithField("transport", "memory"), mem)
						return &transport

View source record →