commons_go/communicate
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

.

Browse Source
This commit is contained in:
jackdaw 2016-11-28 14:44:24 +09:00
parent 62249143f0
commit c7e3881528
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
communicate_test.go
View File

@ -58,6 +58,8 @@ func TestSend(t *testing.T) {
func TestRealSendByGin(t *testing.T) { func TestRealSendByGin(t *testing.T) {
SetRootURL("http://localhost:8080")
e := events.NewEvent(events.CENTRAL_EVENT, events.NewInstallEvent("TestInstallEvent")) e := events.NewEvent(events.CENTRAL_EVENT, events.NewInstallEvent("TestInstallEvent"))
data, _ := json.Marshal(&e) data, _ := json.Marshal(&e)

2
communicator.go
View File

@ -26,7 +26,7 @@ func (c *communicator) start() {
go func(event *events.Event) { go func(event *events.Event) {
m := event.Data.(events.URLMaker) m := event.Data.(events.URLMaker)
data, _ := json.Marshal(event) data, _ := json.Marshal(event)
r, _ := http.Post(m.GetUrl(), "application/json", bytes.NewBuffer(data)) r, _ := http.Post(c.RootURL+m.GetUrl(), "application/json", bytes.NewBuffer(data))
e.Result <- events.Result{Message: r.Status} e.Result <- events.Result{Message: r.Status}
}(e) }(e)
} }