协议网关、消息队列和流处理函数
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

16 lines
292 B

package hpds_node
import (
"github.com/stretchr/testify/assert"
"testing"
"time"
)
func TestMqRun(t *testing.T) {
mq := NewMqWithOptions("mq", WithMqAddr("localhost:9001"))
time.Sleep(time.Second)
assert.NotNil(t, mq)
err := mq.Close()
time.Sleep(time.Second)
assert.Nil(t, err)
}