fix test

liuxiaolong

2020-01-14 f51eaaedb99d04d20500e3c7166b122940f2508d

fix test

 pubsub_test.go

@@ -1,14 +1,13 @@
package pubsub

import (
    "encoding/json"
    "fmt"
    "testing"
    "time"
)

func startServer(url string) {
    pub, err := NewPublisher(url,1)
    pub, err := NewPublisher(url,"tcp://127.0.0.1:5005",1)
    if err !=nil {
        fmt.Println("NEW PUB ERR:",err)
    }
@@ -19,15 +18,14 @@
                Topic: Topic_Task,
                Msg: []byte("tttt"),
            }
            b1, _ := json.Marshal(m1)
            pub.Publish(b1)

            pub.Publish(m1)

            var m2 = Message{
                Topic: Topic_Camera,
                Msg: []byte("5.34"),
            }
            b2, _ := json.Marshal(m2)
            pub.Publish(b2)
            pub.Publish(m2)
        }
    }()
}
@@ -36,7 +34,7 @@
    url := "tcp://0.0.0.0:4005"
    startServer(url)

    sub, err := NewSubscriber(url,1,[]string{ Topic_Camera })
    sub, err := NewSubscriber(url,"tcp://127.0.0.1:5005",1,[]string{ Topic_Camera },"proc")

    if err !=nil {
        fmt.Println("NEW SUB ERR:",err)