| | |
| | | package bhsgo |
| | | |
| | | import ( |
| | | bh "bhshmq/proto/source/bhome_msg" |
| | | "fmt" |
| | | "testing" |
| | | "time" |
| | | "unsafe" |
| | | |
| | | bh "basic.com/valib/bhshmq.git/proto/source/bhome_msg" |
| | | ) |
| | | |
| | | func ServerCallback(src unsafe.Pointer, proc_id *string, req *bh.MsgRequestTopic) { |
| | |
| | | t.Log("register error") |
| | | return |
| | | } |
| | | r = Unregister(&proc, &reply, 1000) |
| | | if r { |
| | | fmt.Println("Unregister ok") |
| | | } else { |
| | | fmt.Println("Unregister failed") |
| | | } |
| | | |
| | | r = Register(&proc, &reply, 1000) |
| | | if r { |
| | | fmt.Println("register ok") |
| | | } else { |
| | | fmt.Println("register failed") |
| | | t.Log("register error") |
| | | return |
| | | } |
| | | |
| | | r = HeartbeatEasy(1000) |
| | | if r { |