yyfbaloot/servers/micros/remotemessage/main.go

package main

import (
	_ "bet24.com/log"
	"bet24.com/servers/micros/common"
	"bet24.com/servers/micros/remotemessage/config"
	"bet24.com/servers/micros/remotemessage/handler"
	pb "bet24.com/servers/micros/remotemessage/proto"
	"fmt"
)

func main() {
	config.Run(pb.ServiceName)
	go waitInput()
	common.RunService(pb.ServiceName, handler.GetInstance(), fmt.Sprintf("localhost:%d", config.Server.ConsulPort))
}

func waitInput() {
	for {
		var cmd string
		var param1 string
		var param2 string
		fmt.Scanf("%s %s %s", &cmd, &param1, &param2)
		switch cmd {
		case "":
			break
		case "clientpool":
			common.DumpClientPools()
		case "exit":
			common.DeregisterService(pb.ServiceName)
		default:
			handler.Dump(cmd, param1, param2)
		}
	}
}