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 |
|
/** |