|
@@ -38,10 +38,10 @@ func SendJson(topic string, v interface{}) {
|
|
|
|
|
|
|
|
func sendJson(topic, contentType string, v interface{}) {
|
|
func sendJson(topic, contentType string, v interface{}) {
|
|
|
b, _ := json.Marshal(v)
|
|
b, _ := json.Marshal(v)
|
|
|
- getStompConnection().Send("/topic/go-battlecamp."+topic, contentType, b, stomp.SendOpt.NoContentLength)
|
|
|
|
|
|
|
+ getStompConnection().Send("/topic/battlecamp-go."+topic, contentType, b, stomp.SendOpt.NoContentLength)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
func Subscribe(topic string) chan *stomp.Message {
|
|
func Subscribe(topic string) chan *stomp.Message {
|
|
|
- result, _ := getStompConnection().Subscribe("/topic/go-battlecamp."+topic, stomp.AckAuto)
|
|
|
|
|
|
|
+ result, _ := getStompConnection().Subscribe("/topic/battlecamp-go."+topic, stomp.AckAuto)
|
|
|
return result.C
|
|
return result.C
|
|
|
}
|
|
}
|