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
}