in internal/protocol/message.go [32:38]
func closeEventMeshClient(client pgrpc.Interface) { if client != nil { if err := client.Close(); err != nil { log.Get(constants.LogSchedule).Errorf("close eventmesh client error:%v", err) } } }