尝试通过github.com/go-stomp/stomp库连接到AWS上的ActiveMQ实例。
以下代码引发invalid command错误:
func (s *STOMP) Init() error {
netConn, err := stomp.Dial("tcp", "host:61614")
if err != nil {
return errors.Wrap(err, "dial to server")
}
s.conn = netConn
return nil
相关分类