Update

bootstrap.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"log"
 
+	"git.apache.org/thrift.git/lib/go/thrift"
 	"github.com/DrWrong/monica/config"
 	"github.com/DrWrong/monica/logger"
 	"github.com/DrWrong/monica/thriftext"
@@ -90,7 +91,7 @@ func BootStrapWeb(postInitFunc func()) {
 	WebServer.Run()
 }
 
-// 起动thrift server
+// BooststrapThrift 起动thrift server
 func BootstrapThrift(processor thrift.TProcessor) {
 	port, err := config.Int("serverport")
 	if err != nil {
@@ -115,12 +116,3 @@ func BootstrapThriftWithPort(processor thrift.TProcessor, port int) {
 	}
 
 }
-
-func StartDm303WhenNeccssary() {
-	config, err := config.Map("dm303")
-	if err != nil {
-		return
-	}
-
-	go dm303_go.Start(config["port"].(int), config["service_name"].(string))
-}

bootstrap_app.go

@@ -168,9 +168,6 @@ func (app *MonicaApp) cliContextRedayHook(c *cli.Context) error {
 	if app.daemon {
 		app.writePidFile()
 	}
-	if app.globalConfigInited {
-		StartDm303WhenNeccssary()
-	}
 	go app.handleSigIntAndTerm()
 	return nil
 }

example/none_daemon.go

@@ -0,0 +1,18 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"github.com/DrWrong/monica"
+	cli "gopkg.in/urfave/cli.v2"
+)
+
+func main() {
+	app := monica.App
+	app.Action = func(c *cli.Context) error {
+		fmt.Println("Hello word")
+		return nil
+	}
+	app.Run(os.Args)
+}

thriftext/thrift_client_pool.go

@@ -191,7 +191,7 @@ func (p *Pool) newThriftClient() (thriftClient ThriftClient, err error) {
 		if err != nil {
 			continue
 		}
-		transport = transportFactory.GetTransport(transport)
+		transport, _ = transportFactory.GetTransport(transport)
 		err = transport.Open()
 		if err == nil {
 			break