Main für Customer-Service customer/service/main.go

main.go

func main() {
	var wg sync.WaitGroup

	wg.Add(1)
	defer wg.Wait()

	flagBind := flag.String("bind", ":9010", "Bind service to address")
	flag.Parse()

	context := actor.EmptyRootContext
	props := actor.PropsFromProducer(customer.NewService)
	pid := context.Spawn(props)

	remote.Start(*flagBind)

	remote.Register("customer", actor.PropsFromFunc(func(ctx actor.Context) {
		ctx.RequestWithCustomSender(pid, ctx.Message(), ctx.Sender())
	}))
}