From d20d0c5a95e19250a7d83b4eb30f9d7b460104da Mon Sep 17 00:00:00 2001
From: adamdottv <2363879+adamdottv@users.noreply.github.com>
Date: Mon, 12 May 2025 11:22:19 -0500
Subject: chore: cleanup

---
 internal/pubsub/broker_test.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

(limited to 'internal')

diff --git a/internal/pubsub/broker_test.go b/internal/pubsub/broker_test.go
index 581a513a3..1a82011fc 100644
--- a/internal/pubsub/broker_test.go
+++ b/internal/pubsub/broker_test.go
@@ -51,12 +51,12 @@ func TestBrokerPublish(t *testing.T) {
 	ch := broker.Subscribe(ctx)
 
 	// Publish a message
-	broker.Publish(CreatedEvent, "test message")
+	broker.Publish("created", "test message")
 
 	// Verify message is received
 	select {
 	case event := <-ch:
-		assert.Equal(t, CreatedEvent, event.Type)
+		assert.Equal(t, "created", event.Type)
 		assert.Equal(t, "test message", event.Payload)
 	case <-time.After(100 * time.Millisecond):
 		t.Fatal("timeout waiting for message")
@@ -122,7 +122,7 @@ func TestBrokerConcurrency(t *testing.T) {
 
 	// Publish messages to all subscribers
 	for i := range numSubscribers {
-		broker.Publish(CreatedEvent, i)
+		broker.Publish("created", i)
 	}
 
 	// Wait for all subscribers to finish
-- 
cgit v1.2.3