I have created custom net TPC connection, and created RPC client with that connection. But it hang forever.
taskGenConn, err := net.Dial("tcp", cfg.TaskGeneratorRPCUrl)
if err != nil {
return err
}
avsTaskGeneratorClient := rpc.NewClient(taskGenConn)
fmt.Println("going to infinite loop....")
err = avsTaskGeneratorClient.Call("UserRPC.AddUser", payload, &reply) // This point hang
if err != nil {
return err
}
If I am doing with avsTaskGeneratorClient, err := rpc.DialHTTP("tcp", cfg.TaskGeneratorRPCUrl)
and Call. It works as expected.
What I am doing wrong?