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:20:54 +09:00
parent c11d0b94de
commit 162392f60b
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
communicate_test.go
View File

@ -50,7 +50,7 @@ func TestSend(t *testing.T) {
})) }))
defer ts.Close() defer ts.Close()
for i := 0; i < 10; i++ { for i := 0; i < 10; i++ {
e := events.NewEvent(events.CENTRAL_EVENT, events.InstallEvent{Message: "Test"}) e := events.NewEvent(events.CENTRAL_EVENT, events.CollectorInstallEvent{Message: "Test"})
Send(e) Send(e)
t.Log(e.GetResult()) t.Log(e.GetResult())
} }

8
events/event_collector.go
View File

@ -1,13 +1,13 @@
package events package events
type InstallEvent struct { type CollectorInstallEvent struct {
Message string Message string
} }
func (i InstallEvent) GetUrl() string { func (i CollectorInstallEvent) GetUrl() string {
return COLLECTOR_INSTALL return COLLECTOR_INSTALL
} }
func NewInstallEvent(message string) *InstallEvent { func NewInstallEvent(message string) *CollectorInstallEvent {
return &InstallEvent{Message: message} return &CollectorInstallEvent{Message: message}
} }