services/test/pubsub/main.go

package main

import (
	"context"
	"fmt"
	"time"

	"github.com/micro/micro/v3/service"
	"github.com/micro/micro/v3/service/logger"
	pb "github.com/micro/services/test/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)
	}
}