fix bug add test

dipperin · Oct 17, 2019 · 3b3b27d · 3b3b27d
1 parent 144e9f9
commit 3b3b27d
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/mq/nsq/receiver_manager_test.go b/mq/nsq/receiver_manager_test.go
@@ -16,6 +16,16 @@ func TestReceiverManager(t *testing.T) {
 	select {}
 }
 
+func TestReceiverManagerNoLookup(t *testing.T) {
+	t.Skip("no run this test")
+	SetLogLv(nsq.LogLevelError)
+	receiver := NewNsqReceiver(&MqHostConfigs{Nsq: []string{"127.0.0.1:4150", "127.0.0.1:4152"}})
+	manager := NewReceiverManager(receiver)
+	manager.Add(GenTask("Topic", "Channel"))
+	manager.Start()
+	select {}
+}
+
 func GenTask(topic, channel string) NsqHandlerFunc {
 	return func() (config *MqTaskConfigs) {
 		return &MqTaskConfigs{