Function TestDisableQueueGroup

micro/test/service_test.go:1871–1912

(t *testing.T)

}

func TestDisableQueueGroup(t *testing.T) {
	s := RunServerOnPort(-1)
	defer s.Shutdown()

	nc, err := nats.Connect(s.ClientURL())
	if err != nil {
		t.Fatalf("Expected to connect to server, got %v", err)
	}
	defer nc.Close()
	wg := sync.WaitGroup{}

	// Create 5 service responders.
	config := micro.Config{
		Name:        "CoolAddService",
		Version:     "0.1.0",
		Description: "Add things together",
		Metadata:    map[string]string{"basic": "metadata"},
		Endpoint: &micro.EndpointConfig{
			Subject: "svc.add",
			Handler: micro.HandlerFunc(func(r micro.Request) {
				r.Respond(nil)
				wg.Done()
			}),
		},
		QueueGroupDisabled: true,
	}

	for range 10 {
		srv, err := micro.AddService(nc, config)
		if err != nil {
			t.Fatalf("Unexpected error: %v", err)
		}
		defer srv.Stop()
	}
	wg.Add(10)
	// Send a request to the service.
	if err = nc.PublishRequest("svc.add", "rply", []byte("req")); err != nil {
		t.Fatalf("Unexpected error: %v", err)
	}
	wg.Wait()

}

func TestEndpointPendingLimits(t *testing.T) {
	s := RunServerOnPort(-1)