Example of subscribe after register.

subscribe.go

package main

import (
	"context"
	"fmt"
	"time"

	"github.com/micro/go-micro"
	"github.com/micro/protobuf/ptypes/wrappers"
)

func main() {
	ctx, cancel := context.WithTimeout(context.Background(), 60*time.Second)
	defer cancel()

	srv := micro.NewService(
		micro.Name("test-service"),
		micro.Context(ctx),
		micro.RegisterInterval(5*time.Second),
	)
	cli := srv.Client()

	go func() {
		fmt.Println("Registering test A subscription")
		err := micro.RegisterSubscriber("testA", srv.Server(), func(ctx context.Context, msg *wrappers.StringValue) error {
			fmt.Println("Got test A", msg.GetValue())
			return nil
		})
		if err != nil {
			panic(err)
		}

		time.Sleep(5 * time.Second)

		fmt.Println("Registering test B subscription")
		err = micro.RegisterSubscriber("testB", srv.Server(), func(ctx context.Context, msg *wrappers.StringValue) error {
			fmt.Println("Got test B", msg.GetValue())
			return nil
		})
		if err != nil {
			panic(err)
		}
	}()


	pubA := micro.NewPublisher("testA", cli)
	pubB := micro.NewPublisher("testB", cli)
	go func() {
		fmt.Println("Running loop")
		t := time.NewTicker(time.Second)
		for {
			select {
			case <-ctx.Done():
				fmt.Println("Finished loop")
				return
			case now := <-t.C:
				msg := &wrappers.StringValue{
					Value: now.String(),
				}
				fmt.Println("Publishing")
				pubA.Publish(ctx, msg)
				pubB.Publish(ctx, msg)
			}
		}
	}()

	time.Sleep(10 * time.Millisecond)
	srv.Run()
}