Function TestOpenTopicFromURL

pubsub/rabbitpubsub/rabbit_test.go:397–442

(t *testing.T)

}

func TestOpenTopicFromURL(t *testing.T) {
	t.Setenv("RABBIT_SERVER_URL", rabbitURL)

	tests := []struct {
		label       string
		URLTemplate string
		WantErr     bool
	}{
		{"valid url", "rabbit://%s", false},
		{"valid url with key name parameter", "rabbit://%s?key_name=foo", false},
		{"invalid url with parameters", "rabbit://%s?param=value", true},
		{"invalid url with key name parameter", "rabbit://%s?key_name=", true},
	}

	for _, test := range tests {
		t.Run(test.label, func(t *testing.T) {
			conn := mustDialRabbit(t)
			_, isFake := conn.(*fakeConnection)
			if isFake {
				t.Skip("test requires real rabbitmq")
			}

			h := &harness{conn: conn}

			ctx := context.Background()

			dt, cleanupTopic, err := h.CreateTopic(ctx, t.Name())
			if err != nil {
				t.Fatalf("unable to create topic: %v", err)
			}

			t.Cleanup(cleanupTopic)

			exchange := dt.(*topic).exchange
			url := fmt.Sprintf(test.URLTemplate, exchange)

			topic, err := pubsub.OpenTopic(ctx, url)
			if (err != nil) != test.WantErr {
				t.Errorf("%s: got error %v, want error %v", test.URLTemplate, err, test.WantErr)
			}
			if topic != nil {
				topic.Shutdown(ctx)
			}
		})
	}
}

func TestOpenSubscriptionFromURL(t *testing.T) {
	t.Setenv("RABBIT_SERVER_URL", rabbitURL)