1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
| package main
|
| import (
| "basic.com/valib/pubsub.git"
| )
|
| // Init init tcp://192.168.5.22:4005
| func Init(url, heartBeatURL string, mode int, topics []string, processID string) (chan pubsub.Message, error) {
| p, err := pubsub.NewSubscriber(url, heartBeatURL, mode, topics, processID)
| if err != nil {
| return nil, err
| }
| c := p.Recv()
| return c, err
| }
|
|
