Set up typo fix
This commit is contained in:
parent
302243dd39
commit
b0daf020de
@ -59,7 +59,7 @@ EOF
|
|||||||
$io = new SymfonyStyle($input, $output);
|
$io = new SymfonyStyle($input, $output);
|
||||||
|
|
||||||
$transportNames = $this->transportNames;
|
$transportNames = $this->transportNames;
|
||||||
// do we want to setup only one transport?
|
// do we want to set up only one transport?
|
||||||
if ($transport = $input->getArgument('transport')) {
|
if ($transport = $input->getArgument('transport')) {
|
||||||
if (!$this->transportLocator->has($transport)) {
|
if (!$this->transportLocator->has($transport)) {
|
||||||
throw new \RuntimeException(sprintf('The "%s" transport does not exist.', $transport));
|
throw new \RuntimeException(sprintf('The "%s" transport does not exist.', $transport));
|
||||||
@ -71,7 +71,7 @@ EOF
|
|||||||
$transport = $this->transportLocator->get($transportName);
|
$transport = $this->transportLocator->get($transportName);
|
||||||
if ($transport instanceof SetupableTransportInterface) {
|
if ($transport instanceof SetupableTransportInterface) {
|
||||||
$transport->setup();
|
$transport->setup();
|
||||||
$io->success(sprintf('The "%s" transport was setup successfully.', $transportName));
|
$io->success(sprintf('The "%s" transport was set up successfully.', $transportName));
|
||||||
} else {
|
} else {
|
||||||
$io->note(sprintf('The "%s" transport does not support setup.', $transportName));
|
$io->note(sprintf('The "%s" transport does not support setup.', $transportName));
|
||||||
}
|
}
|
||||||
|
@ -42,7 +42,7 @@ class SetupTransportsCommandTest extends TestCase
|
|||||||
$tester->execute([]);
|
$tester->execute([]);
|
||||||
$display = $tester->getDisplay();
|
$display = $tester->getDisplay();
|
||||||
|
|
||||||
$this->assertStringContainsString('The "amqp" transport was setup successfully.', $display);
|
$this->assertStringContainsString('The "amqp" transport was set up successfully.', $display);
|
||||||
$this->assertStringContainsString('The "other_transport" transport does not support setup.', $display);
|
$this->assertStringContainsString('The "other_transport" transport does not support setup.', $display);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -66,7 +66,7 @@ class SetupTransportsCommandTest extends TestCase
|
|||||||
$tester->execute(['transport' => 'amqp']);
|
$tester->execute(['transport' => 'amqp']);
|
||||||
$display = $tester->getDisplay();
|
$display = $tester->getDisplay();
|
||||||
|
|
||||||
$this->assertStringContainsString('The "amqp" transport was setup successfully.', $display);
|
$this->assertStringContainsString('The "amqp" transport was set up successfully.', $display);
|
||||||
}
|
}
|
||||||
|
|
||||||
public function testReceiverNameArgumentNotFound()
|
public function testReceiverNameArgumentNotFound()
|
||||||
|
@ -334,7 +334,7 @@ class Connection
|
|||||||
}
|
}
|
||||||
} catch (\AMQPQueueException $e) {
|
} catch (\AMQPQueueException $e) {
|
||||||
if (404 === $e->getCode() && $this->shouldSetup()) {
|
if (404 === $e->getCode() && $this->shouldSetup()) {
|
||||||
// If we get a 404 for the queue, it means we need to setup the exchange & queue.
|
// If we get a 404 for the queue, it means we need to set up the exchange & queue.
|
||||||
$this->setupExchangeAndQueues();
|
$this->setupExchangeAndQueues();
|
||||||
|
|
||||||
return $this->get();
|
return $this->get();
|
||||||
|
Reference in New Issue
Block a user