|
@@ -67,6 +67,14 @@ func main() {
|
|
|
return
|
|
|
}
|
|
|
log.Println("[RESULT]<-", string(rsp.Data))
|
|
|
+ // 获取长数据
|
|
|
+ rsp = hub.GetOne(regexp.MustCompile(remoteChannel), "bigdata", nil)
|
|
|
+ if rsp.State != config.STATE_OK {
|
|
|
+ log.Println("error state:", rsp.State)
|
|
|
+ return
|
|
|
+ } else {
|
|
|
+ log.Println("get bigdata ok")
|
|
|
+ }
|
|
|
|
|
|
time.Sleep(time.Second * 5)
|
|
|
hub.Push(regexp.MustCompile(remoteChannel), "push", []byte(time.Now().GoString()))
|