One

pubsub/main.go

@@ -0,0 +1,50 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"time"
+
+	"github.com/micro/micro/v3/service"
+	"github.com/micro/micro/v3/service/logger"
+	pb "github.com/micro/services/pubsub/proto"
+)
+
+// Pub will publish messages every second
+func Pub() {
+	ev := service.NewEvent("messages")
+
+	for {
+		err := ev.Publish(context.TODO(), &pb.Message{
+			Id:   "1",
+			Body: []byte(`hello`),
+		})
+		if err != nil {
+			logger.Error("Error Publish:", err.Error())
+		}
+
+		time.Sleep(time.Second)
+	}
+}
+
+// Sub processes messages
+func Sub(ctx context.Context, msg *pb.Message) error {
+	fmt.Println("Received a message")
+	return nil
+}
+
+func main() {
+	service := service.New(
+		service.Name("pubsub"),
+	)
+
+	// subscribe to the "messages" topic
+	service.Subscribe("messages", Sub)
+
+	// publish messages
+	go Pub()
+
+	if err := service.Run(); err != nil {
+		fmt.Println(err)
+	}
+}