Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- func run (appName string) (err error) {
- done = make(chan bool)
- defer close(done)
- serviceURL, e := GetContext().getServiceURL(appName)
- if e != nil {
- err = errors.New("process failed" + err.Error())
- LogDebug("Exiting %v func[err =%v]", methodName, err)
- return err
- }
- url := "wss://" + serviceURL + route
- stateMachine = 0
- socket := gowebsocket.New(url)
- addPass(&socket, user, pass)
- socket.OnConnectError = OnConnectErrorHandler
- socket.OnConnected = OnConnectedHandler
- socket.OnTextMessage = socketTextMessageHandler
- socket.OnDisconnected = OnDisconnectedHandler
- LogDebug("In %v func connecting to URL %v", methodName, url)
- socket.Connect()
- jsonBytes, e := json.Marshal(payload)
- if e != nil {
- err = errors.New("build process failed" + e.Error())
- LogDebug("Exiting %v func[err =%v]", methodName, err)
- return err
- }
- jsonStr := string(jsonBytes)
- LogDebug("In %v Connecting to payload JSON is %v", methodName, jsonStr)
- socket.SendText(jsonStr)
- <-done
- LogDebug("Exiting %v func[err =%v]", methodName, err)
- return err
- }
- func OnConnectErrorHandler(err error, socket gowebsocket.Socket) {
- methodName := "OnConnectErrorHandler"
- LogDebug("Starting %v parameters [err = %v , socket = %v]", methodName, err, socket)
- LogInfo("Disconnected from server ")
- done <- true
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement