diff --git a/rtmp/rtmp.go b/rtmp/rtmp.go index 9496fbb6..de67219e 100644 --- a/rtmp/rtmp.go +++ b/rtmp/rtmp.go @@ -409,8 +409,8 @@ func startSession(rtmp *C.RTMP, u string, timeout uint32) (*C.RTMP, error) { //C.RTMP_EnableWrite(rtmp) rtmpSetBufferMS(rtmp, 3600*1000) //C.RTMP_SetBufferMS(rtmp, 3600*1000) - // if rtmpConnect(rtmp, nil) == 0 { - if C.RTMP_Connect(rtmp, nil) == 0 { + if rtmpConnect(rtmp, nil) == 0 { + //if C.RTMP_Connect(rtmp, nil) == 0 { //C.RTMP_Close(rtmp) //C.RTMP_Free(rtmp) return nil, errors.New("rtmp startSession: Failed to connect!")