chore: update

golang-queue · Dec 5, 2023 · d6942f8 · d6942f8
1 parent c6d47dc
commit d6942f8
Showing 1 changed file with 21 additions and 0 deletions.
diff --git a/nats_test.go b/nats_test.go
@@ -53,6 +53,27 @@ func TestDefaultFlow(t *testing.T) {
 	q.Release()
 }
 
+func TestClusteredHost(t *testing.T) {
+	m := &mockMessage{
+		Message: "foo",
+	}
+	w := NewWorker(
+		WithAddr(host, "nats://localhost:4223"),
+		WithSubj("test"),
+		WithQueue("test"),
+	)
+	q, err := queue.NewQueue(
+		queue.WithWorker(w),
+		queue.WithWorkerCount(1),
+	)
+	assert.NoError(t, err)
+	assert.NoError(t, q.Queue(m))
+	assert.NoError(t, q.Queue(m))
+	q.Start()
+	time.Sleep(500 * time.Millisecond)
+	q.Release()
+}
+
 func TestShutdown(t *testing.T) {
 	w := NewWorker(
 		WithAddr(host),