Manager/ExchangeManager.php 1 location
|
@@ 28-31 (lines=4) @@
|
25 |
|
$configuration->getClient()->exchanges()->create($configuration->getName(), $name, $exchange); |
26 |
|
} |
27 |
|
|
28 |
|
if ($configuration->isDeleteAllowed() && isset($remoteExchange) && !$this->isUpToDate($exchange, $remoteExchange)) { |
29 |
|
$configuration->getClient()->exchanges()->delete($configuration->getName(), $name); |
30 |
|
$configuration->getClient()->exchanges()->create($configuration->getName(), $name, $exchange); |
31 |
|
} |
32 |
|
} |
33 |
|
} |
34 |
|
} |
Manager/PermissionManager.php 1 location
|
@@ 24-27 (lines=4) @@
|
21 |
|
$configuration->getClient()->permissions()->create($configuration->getName(), $user, $permission); |
22 |
|
} |
23 |
|
|
24 |
|
if ($configuration->isDeleteAllowed() && isset($remotePermission) && !$this->isUpToDate($permission, $remotePermission)) { |
25 |
|
$configuration->getClient()->permissions()->delete($configuration->getName(), $user); |
26 |
|
$configuration->getClient()->permissions()->create($configuration->getName(), $user, $permission); |
27 |
|
} |
28 |
|
} |
29 |
|
} |
30 |
|
} |
Manager/QueueManager.php 1 location
|
@@ 79-82 (lines=4) @@
|
76 |
|
$configuration->getClient()->queues()->create($configuration->getName(), $name, $queue); |
77 |
|
} |
78 |
|
|
79 |
|
if ($configuration->isDeleteAllowed() && isset($remoteQueue) && !$this->isUpToDate($queue, $remoteQueue)) { |
80 |
|
$configuration->getClient()->queues()->delete($configuration->getName(), $name); |
81 |
|
$configuration->getClient()->queues()->create($configuration->getName(), $name, $queue); |
82 |
|
} |
83 |
|
} |
84 |
|
|
85 |
|
/** |