Public/ps1/Job/Start-LeftConnectRemoteJobThread.ps1
|
$threadPreparation = { #import-module UblionConnect } # This is the main entry point function Start-LeftConnectRemoteJobThread { param ($name) try { $runningProcesses = (Get-Job -ErrorAction SilentlyContinue) | Where-object {$_.Name.Contains(("UblionConnect"+$name))} $runningProcesses | Where-Object {$_.State -ne "Running"} | %{ Stop-Job $_ #-ErrorAction SilentlyContinue Remove-Job $_# -ErrorAction SilentlyContinue } $runningProcesses = (Get-Job -ErrorAction SilentlyContinue) | Where-object {$_.Name.Contains(("UblionConnect"+$name))} if (($runningProcesses | Where-Object {$_.State -eq "Running"}).Count -ge 1) { return } else { $extension = [int]([int](Get-Date -UFormat %s -Millisecond 0) / 60) $directProcessing = Get-ConfigurationValue -name ($name+"DirectProcessing") -defaultValue $false # Start-Job -InitializationScript $threadPreparation -Name ("UblionConnect"+$name+$extension) -ScriptBlock { Start-Job -Name ("UblionConnect"+$name+$extension) -ScriptBlock { param ($sleepTime, $pipeline, $directProcessing) import-module UblionConnect -ErrorAction SilentlyContinue -WarningAction SilentlyContinue while ($true) { $result = Get-LeftConnectRemoteJob -channel $pipeline [system.gc]::Collect() Log "$pipeline : Getting job $directProcessing and result $result waiting for $sleepTime" if ($directProcessing -and $result -eq $false) { Start-Sleep -seconds $sleepTime } elseif ($directProcessing -and $result) { } else { Start-Sleep -seconds $sleepTime } } } -ArgumentList (Get-ConfigurationValue -name ($name+"Sleep") ), $name, $directProcessing Log "Starting job instance $(("UblionConnect"+$name+$extension))" } } catch { Log $_ } } |