forked from mariuszwojcik/RabbitMQTools
-
Notifications
You must be signed in to change notification settings - Fork 0
/
RemoveQueue.ps1
115 lines (86 loc) · 4.42 KB
/
RemoveQueue.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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
<#
.Synopsis
Removes Queue from RabbitMQ server.
.DESCRIPTION
The Remove-RabbitMQQueue allows for removing queues in given RabbitMQ server. This cmdlet is marked with High impact.
To remove Queue from remote server you need to provide -ComputerName.
You may pipe an object with names and, optionally, with computer names to remove multiple Queues. For more information how to do that see Examples.
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
Remove-RabbitMQQueue q1 -VirtualHost vh1
This command removes Queue named "q1" from virtual host vh1 located in local RabbitMQ server.
.EXAMPLE
Remove-RabbitMQQueue q1, q2 -VirtualHost vh1
This command removes Queues named "q1" and "q2" from local RabbitMQ server.
.EXAMPLE
Remove-RabbitMQQueue test -VirtualHost vh1 -ComputerName myrabbitmq.servers.com
This command removes Queue named "test" from myrabbitmq.servers.com server.
.EXAMPLE
@("q1", "q2") | Remove-RabbitMQQueue -VirtualHost vh1
This command pipes list of Queues to be removed from the RabbitMQ server. In the above example two Queues named "q1" and "q2" will be removed from local RabbitMQ server.
.EXAMPLE
$a = $(
New-Object -TypeName psobject -Prop @{"ComputerName" = "localhost"; "Name" = "e1"}
New-Object -TypeName psobject -Prop @{"ComputerName" = "localhost"; "Name" = "e2"}
New-Object -TypeName psobject -Prop @{"ComputerName" = "127.0.0.1"; "Name" = "e3"}
)
$a | Remove-RabbitMQQueue
Above example shows how to pipe both Exchange name and Computer Name to specify server from which the Exchange should be removed.
In the above example two Exchanges named "e1" and "e2" will be removed from RabbitMQ local server, and one Exchange named "e3" will be removed from the server 127.0.0.1.
.INPUTS
You can pipe Exchange names and optionally ComputerNames to this cmdlet.
.LINK
https://www.rabbitmq.com/management.html - information about RabbitMQ management plugin.
#>
function Remove-RabbitMQQueue
{
[CmdletBinding(DefaultParameterSetName='defaultLogin', SupportsShouldProcess=$true, ConfirmImpact="High")]
Param
(
# Name of RabbitMQ Queue.
[parameter(Mandatory=$true, ValueFromPipeline=$true, ValueFromPipelineByPropertyName=$true, Position=0)]
[Alias("queue", "QueueName")]
[string[]]$Name,
# Name of RabbitMQ Virtual Host.
[parameter(ValueFromPipelineByPropertyName=$true)]
[Alias("vh", "vhost")]
[string]$VirtualHost = $defaultVirtualhost,
# Name of the computer hosting RabbitMQ server. Defalut value is localhost.
[parameter(ValueFromPipelineByPropertyName=$true)]
[Alias("HostName", "hn", "cn")]
[string]$ComputerName = $defaultComputerName,
# UserName to use when logging to RabbitMq server.
[Parameter(Mandatory=$true, ParameterSetName='login')]
[string]$UserName,
# Password to use when logging to RabbitMq server.
[Parameter(Mandatory=$true, ParameterSetName='login')]
[string]$Password,
# Credentials to use when logging to RabbitMQ server.
[Parameter(Mandatory=$true, ParameterSetName='cred')]
[PSCredential]$Credentials
)
Begin
{
$Credentials = NormaliseCredentials
$cnt = 0
}
Process
{
if ($pscmdlet.ShouldProcess("server: $ComputerName, vhost: $VirtualHost", "Remove queue(s): $(NamesToString $Name '(all)')"))
{
foreach($n in $Name)
{
$url = "http://$([System.Web.HttpUtility]::UrlEncode($ComputerName)):15672/api/queues/$([System.Web.HttpUtility]::UrlEncode($VirtualHost))/$([System.Web.HttpUtility]::UrlEncode($n))"
Write-Verbose "Invoking REST API: $url"
$result = Invoke-RestMethod $url -Credential $Credentials -AllowEscapedDotsAndSlashes -DisableKeepAlive -ErrorAction Continue -Method Delete
Write-Verbose "Deleted Queue $n on server $ComputerName, Virtual Host $VirtualHost"
$cnt++
}
}
}
End
{
if ($cnt -gt 1) { Write-Verbose "Deleted $cnt Queue(s)." }
}
}