upgrade version to v0.0.12

dobyte · Mar 10, 2023 · 8074a4c · 8074a4c
1 parent 4e8579d
commit 8074a4c
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/eventbus/nats/eventbus_test.go b/eventbus/nats/eventbus_test.go
@@ -4,7 +4,6 @@ import (
 	"context"
 	"github.com/dobyte/due/eventbus"
 	"github.com/dobyte/due/eventbus/nats"
-	"github.com/dobyte/due/eventbus/redis"
 	"log"
 	"testing"
 	"time"
@@ -79,7 +78,7 @@ func TestEventbus_Client2_Subscribe(t *testing.T) {
 func TestEventbus_Publish(t *testing.T) {
 	var (
 		err error
-		eb  = redis.NewEventbus()
+		eb  = nats.NewEventbus()
 		ctx = context.Background()
 	)
 
@@ -95,5 +94,10 @@ func TestEventbus_Publish(t *testing.T) {
 		t.Fatal(err)
 	}
 
+	err = eb.Publish(ctx, loginTopic, "login")
+	if err != nil {
+		t.Fatal(err)
+	}
+
 	t.Log("publish success")
 }