Public/Clear-RabbitMQQueue.ps1
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 |
<# .Synopsis Purges all messages from RabbitMQ Queue. .DESCRIPTION The Clear-RabbitMQQueue removes all messages from given RabbitMQ queue. To remove message from Queue on remote server you need to provide -HostName. The cmdlet is using REST Api provided by RabbitMQ Management Plugin. For more information go to: https://www.rabbitmq.com/management.html To support requests using default virtual host (/), the cmdlet will temporarily disable UnEscapeDotsAndSlashes flag on UriParser. For more information check get-help about_UnEsapingDotsAndSlashes. .EXAMPLE Clear-RabbitMQQueue vh1 q1 Removes all messages from queue "q1" in Virtual Host "vh1" on local computer. .EXAMPLE Clear-RabbitMQQueue -VirtualHost vh1 -Name q1 Removes all messages from queue "q1" in Virtual Host "vh1" on local computer. .EXAMPLE Clear-RabbitMQQueue -VirtualHost vh1 -Name q1 -HostName rabbitmq.server.com Removes all messages from queue "q1" in Virtual Host "vh1" on "rabbitmq.server.com" server. #> function Clear-RabbitMQQueue { [CmdletBinding(SupportsShouldProcess=$true, ConfirmImpact="High")] Param ( # Name of RabbitMQ Virtual Host. [parameter(Mandatory=$false, ValueFromPipelineByPropertyName=$true, Position=0)] [Alias("vh", "vhost")] [string]$VirtualHost = $defaultVirtualHost, # The name of the queue from which to receive messages [parameter(Mandatory=$true, ValueFromPipelineByPropertyName=$true, Position=1)] [Alias("qn", "QueueName")] [string]$Name, # Name of the computer hosting RabbitMQ server. Defalut value is localhost. [parameter(ValueFromPipelineByPropertyName=$true, Position=2)] [Alias("cn", "HostName")] [string]$BaseUri = $defaultComputerName, # Credentials to use when logging to RabbitMQ server. [Parameter(Mandatory=$false)] [PSCredential]$Credentials = $defaultCredentials ) Begin { } Process { if ($pscmdlet.ShouldProcess("server: $BaseUri/$VirtualHost", "purge queue $Name")) { $url = Join-Parts $BaseUri "/api/queues/$([System.Web.HttpUtility]::UrlEncode($VirtualHost))/$([System.Web.HttpUtility]::UrlEncode($Name))/contents" Write-Verbose "Invoking REST API: $url" $result = Invoke-RestMethod $url -Credential $Credentials -AllowEscapedDotsAndSlashes -DisableKeepAlive:$InvokeRestMethodKeepAlive -ErrorAction Continue -Method Delete } } End { } } |