|
|
@@ -72,7 +72,7 @@ func main() {
|
|
|
|
|
|
// 获取信息
|
|
|
rsp := hub.GetOne(remoteFilter, "hello", "hello from client,hello from client,hello from client")
|
|
|
- if rsp.State != config.STATE_OK {
|
|
|
+ if rsp.State != tinymq.STATE_OK {
|
|
|
log.Println("error state:", rsp.State)
|
|
|
return
|
|
|
}
|
|
|
@@ -80,14 +80,14 @@ func main() {
|
|
|
rsp = hub.GetOne(remoteFilter, "hello", func() ([]byte, error) {
|
|
|
return []byte("hello from data function"), nil
|
|
|
})
|
|
|
- if rsp.State != config.STATE_OK {
|
|
|
+ if rsp.State != tinymq.STATE_OK {
|
|
|
log.Println("error state:", rsp.State)
|
|
|
return
|
|
|
}
|
|
|
log.Println("[RESULT]<-", string(rsp.Data))
|
|
|
// 获取长数据
|
|
|
rsp = hub.GetOne(remoteFilter, "bigdata", nil)
|
|
|
- if rsp.State != config.STATE_OK {
|
|
|
+ if rsp.State != tinymq.STATE_OK {
|
|
|
log.Println("error state:", rsp.State)
|
|
|
return
|
|
|
} else {
|