| | |
| | | |
| | | import ( |
| | | "encoding/json" |
| | | "gat1400Exchange/pkg" |
| | | "gat1400Exchange/pkg/logger" |
| | | "gat1400Exchange/util" |
| | | "gat1400Exchange/vo" |
| | | ) |
| | | |
| | |
| | | return clientStatus |
| | | } |
| | | |
| | | rsp, err := util.HttpPost(url, headers, msg) |
| | | rsp, err := pkg.HttpPost(url, headers, msg) |
| | | if err != nil { |
| | | logger.Warn("Post notification failed, %s", err.Error()) |
| | | return vo.StatusOtherError |
| | |
| | | // return clientStatus |
| | | //} |
| | | |
| | | rsp, err := util.HttpPost(url, headers, msg) |
| | | rsp, err := pkg.HttpPost(url, headers, msg) |
| | | if err != nil { |
| | | logger.Warn("Post subscribe failed, %s", err.Error()) |
| | | return vo.StatusOtherError |
| | |
| | | } |
| | | |
| | | func UpdateSubscribe(url string, msg []byte) int { |
| | | rsp, err := util.HttpPut(url, headers, msg) |
| | | rsp, err := pkg.HttpPut(url, headers, msg) |
| | | if err != nil { |
| | | logger.Warn("Put subscribe failed, %s", err.Error()) |
| | | return vo.StatusOtherError |
| | |
| | | } |
| | | |
| | | func GetSubscribes(url string) ([]byte, error) { |
| | | rsp, err := util.HttpGet(url, headers) |
| | | rsp, err := pkg.HttpGet(url, headers) |
| | | if err != nil { |
| | | logger.Warn("Get subscribe failed, %s", err.Error()) |
| | | } |