- tc.Rmr = xapp.NewRMRClientWithParams("tcp:"+strconv.FormatUint(uint64(srcId.Port), 10), 65534, 1, 0, stat)
- tc.Rmr.SetReadyCB(tc.ReadyCB, nil)
- go tc.Rmr.Start(tc)
+ tc.RMRClient = xapp.NewRMRClientWithParams(&xapp.RMRClientParams{
+ StatDesc: statDesc,
+ RmrData: xapp.PortData{
+ Name: "", // Not used currently
+ Port: int(srcId.Port),
+ MaxSize: 65534,
+ ThreadType: 0,
+ LowLatency: false,
+ FastAck: false,
+ //Policies: // Not used currently
+ MaxRetryOnFailure: 1,
+ },
+ })
+
+ tc.RMRClient.SetReadyCB(tc.ReadyCB, nil)
+ go tc.RMRClient.Start(tc)