diff --git a/src/contexts/ctx/ctx_init.go b/src/contexts/ctx/ctx_init.go index 37c4fa80..fd236e58 100644 --- a/src/contexts/ctx/ctx_init.go +++ b/src/contexts/ctx/ctx_init.go @@ -86,7 +86,8 @@ var Index = &Context{Name: "ctx", Help: "模块中心", Server: &CTX{}, "page_offset": &Config{Name: "page_offset", Value: "0", Help: "列表偏移"}, "page_limit": &Config{Name: "page_limit", Value: "10", Help: "列表大小"}, - "time_format": &Config{Name: "time_format", Value: "2006-01-02 15:04:05", Help: "时间格式"}, + "time_format": &Config{Name: "time_format", Value: "2006-01-02 15:04:05", Help: "时间格式"}, + "call_timeout": &Config{Name: "call_timeout", Value: "10s", Help: "回调超时"}, }, Commands: map[string]*Command{ "init": &Command{Name: "init", Help: "启动", Hand: func(m *Message, c *Context, key string, arg ...string) (e error) { diff --git a/src/contexts/ctx/ctx_type.go b/src/contexts/ctx/ctx_type.go index 11038d8c..1ae41754 100644 --- a/src/contexts/ctx/ctx_type.go +++ b/src/contexts/ctx/ctx_type.go @@ -1324,7 +1324,7 @@ func (m *Message) CallBack(sync bool, cb func(msg *Message) (sub *Message), arg m.Log("sync", m.Format("wait", "result", "append")) select { - case <-time.After(kit.Duration("30s")): + case <-time.After(kit.Duration(m.Conf("call_timeout"))): m.Log("sync", m.Format("timeout", "result", "append")) case <-wait: }