pinguin-server/stomp/stomp.go

package stomp

import (
	"encoding/json"
	"log"

	"battlecamp-go-server/flag"

	"github.com/go-stomp/stomp"
)

var stompConnection *stomp.Conn

func getStompConnection() *stomp.Conn {
	if stompConnection == nil {
		stompConnection, _ = stomp.Dial("tcp", *flag.StompUrl)
	}
	return stompConnection
}

func SendJson(topic string, v interface{}) {
	b, _ := json.Marshal(v)
	log.Printf("Sending stomp to topic %v\n", topic)
	getStompConnection().Send("/topic/go-battlecamp."+topic, "application/json;charset=utf-8", b, stomp.SendOpt.NoContentLength)
}