tested examples for channel and redis pubsub

README.md

@@ -0,0 +1,2 @@
+# hiboot-messaging
+

examples/channel-pubsub/main.go

@@ -2,24 +2,32 @@ package main
 
 import (
 	"context"
+	"encoding/json"
+	"github.com/hidevopsio/hiboot-messaging/pubsub"
 	"github.com/hidevopsio/hiboot/pkg/log"
 	"github.com/hidevopsio/hiboot/pkg/utils/idgen"
-	"hiboot-messaging/pubsub"
 	"time"
 )
 
 type FooReceivedEvent struct {
-	ID string
-
+	ID   string
 	Name string
 }
 
+func (e *FooReceivedEvent) MarshalBinary() ([]byte, error) {
+	return json.Marshal(e)
+}
+
+func (e *FooReceivedEvent) UnmarshalBinary(data []byte) error {
+	return json.Unmarshal(data, e)
+}
+
 func main() {
 	// Example of creating a new Redis client and RedisPubSub instance
 
-	chnPubSub := pubsub.NewChannelPubSub[FooReceivedEvent]()
+	fooReceivedEventPubSub := pubsub.NewChannelPubSub[*FooReceivedEvent]()
 	ctx := context.Background()
-	ch, err := chnPubSub.Subscribe(ctx, "foo")
+	ch, err := fooReceivedEventPubSub.Subscribe(ctx, "foo")
 	if err != nil {
 		log.Errorf("Error subscribing: %v", err)
 		return
@@ -31,11 +39,11 @@ func main() {
 			time.Sleep(5 * time.Second)
 			var id string
 			id, err = idgen.NextString()
-			event := FooReceivedEvent{
+			event := &FooReceivedEvent{
 				ID:   id,
 				Name: "Test Event",
 			}
-			err = chnPubSub.Publish(ctx, "foo", event)
+			err = fooReceivedEventPubSub.Publish(ctx, "foo", event)
 			if err != nil {
 				log.Error(err)
 			}

go.mod

@@ -82,7 +82,7 @@ require (
 	gopkg.in/yaml.v2 v2.4.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )
-
-replace (
-	github.com/hidevopsio/hiboot-data => ../hiboot-data
-)
+//
+//replace (
+//	github.com/hidevopsio/hiboot-data => ../hiboot-data
+//)