27 lines
530 B
Go
27 lines
530 B
Go
package mq
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
|
|
"gitea.ddegame.cn/open/servicebase/pkg/common"
|
|
"gitea.ddegame.cn/open/servicebase/pkg/partner/mq/message"
|
|
|
|
"github.com/anxpp/beego"
|
|
)
|
|
|
|
func TestRocket(t *testing.T) {
|
|
e := client.PushRegisterMessage(message.RegisterMessage{
|
|
Message: message.Message{
|
|
MessageId: "001",
|
|
},
|
|
Platform: "android",
|
|
UserId: "001",
|
|
DeviceId: "001",
|
|
RegisterTime: beego.Date(time.Now(), common.TimeDefaultFormat),
|
|
ChannelCode: "001",
|
|
Ip: "0.0.0.0",
|
|
})
|
|
println(e)
|
|
}
|