Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit 2c448d8

Browse filesBrowse files
weaverryanweaverryan
committed
Removing purge()
1 parent b395020 commit 2c448d8
Copy full SHA for 2c448d8

14 files changed

+6
-116
lines changed

‎src/Symfony/Component/Messenger/Command/FailedMessagesPurgeCommand.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Command/FailedMessagesPurgeCommand.php
+6-23Lines changed: 6 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -37,18 +37,16 @@ protected function configure(): void
3737
{
3838
$this
3939
->setDefinition([
40-
new InputArgument('id', InputArgument::OPTIONAL, 'Specific message id to remove'),
40+
new InputArgument('id', InputArgument::REQUIRED, 'Specific message id to remove'),
4141
new InputOption('force', null, InputOption::VALUE_NONE, 'Force the operation without confirmation'),
4242
])
43-
->setDescription('Remove one or more messages from the failure transport.')
43+
->setDescription('Remove a message from the failure transport.')
4444
->setHelp(<<<'EOF'
45-
The <info>%command.name%</info> removes message that are waiting in the failure transport.
46-
47-
<info>php %command.full_name%</info>
48-
49-
Or remove a specific id, which can be found via the messenger:failed:show command:
45+
The <info>%command.name%</info> removes a message that is waiting in the failure transport.
5046
5147
<info>php %command.full_name% {id}</info>
48+
49+
The specific id can be found via the messenger:failed:show command.
5250
EOF
5351
)
5452
;
@@ -64,11 +62,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
6462
$receiver = $this->getReceiver();
6563

6664
$shouldForce = $input->getOption('force');
67-
if (null === $id = $input->getArgument('id')) {
68-
$this->removeAllMessages($receiver, $io, $shouldForce);
69-
} else {
70-
$this->removeSingleMessage($id, $receiver, $io, $shouldForce);
71-
}
65+
$this->removeSingleMessage($input->getArgument('id'), $receiver, $io, $shouldForce);
7266
}
7367

7468
private function removeSingleMessage($id, ReceiverInterface $receiver, SymfonyStyle $io, bool $shouldForce)
@@ -91,15 +85,4 @@ private function removeSingleMessage($id, ReceiverInterface $receiver, SymfonySt
9185
$io->note('Message not remove.');
9286
}
9387
}
94-
95-
private function removeAllMessages(ReceiverInterface $receiver, SymfonyStyle $io, bool $shouldForce)
96-
{
97-
if ($shouldForce || $io->confirm('Do you want to permanently remove ALL failed messages ?', false)) {
98-
$receiver->purge();
99-
100-
$io->success('All messages were removed.');
101-
} else {
102-
$io->note('Messages not remove.');
103-
}
104-
}
10588
}

‎src/Symfony/Component/Messenger/Tests/DependencyInjection/MessengerPassTest.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Tests/DependencyInjection/MessengerPassTest.php
-5Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -628,11 +628,6 @@ public function ack(Envelope $envelope): void
628628
public function reject(Envelope $envelope): void
629629
{
630630
}
631-
632-
public function purge(): void
633-
{
634-
// TODO: Implement purge() method.
635-
}
636631
}
637632

638633
class InvalidReceiver

‎src/Symfony/Component/Messenger/Tests/RetryIntegrationTest.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Tests/RetryIntegrationTest.php
-4Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -90,10 +90,6 @@ public function reject(Envelope $envelope): void
9090
{
9191
}
9292

93-
public function purge(): void
94-
{
95-
}
96-
9793
public function send(Envelope $envelope): Envelope
9894
{
9995
$this->messagesWaiting[] = $envelope;

‎src/Symfony/Component/Messenger/Tests/Transport/Receiver/SingleMessageReceiverTest.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Tests/Transport/Receiver/SingleMessageReceiverTest.php
-2Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,11 +42,9 @@ public function testCallsAreForwarded()
4242
$innerReceiver = $this->createMock(ReceiverInterface::class);
4343
$innerReceiver->expects($this->once())->method('ack')->with($envelope);
4444
$innerReceiver->expects($this->once())->method('reject')->with($envelope);
45-
$innerReceiver->expects($this->once())->method('purge');
4645

4746
$receiver = new SingleMessageReceiver($innerReceiver, $envelope);
4847
$receiver->ack($envelope);
4948
$receiver->reject($envelope);
50-
$receiver->purge();
5149
}
5250
}

‎src/Symfony/Component/Messenger/Tests/WorkerTest.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Tests/WorkerTest.php
-4Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -360,8 +360,4 @@ public function getRejectCount(): int
360360
{
361361
return $this->rejectCount;
362362
}
363-
364-
public function purge(): void
365-
{
366-
}
367363
}

‎src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpReceiver.php
-12Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -105,18 +105,6 @@ public function reject(Envelope $envelope): void
105105
);
106106
}
107107

108-
/**
109-
* {@inheritdoc}
110-
*/
111-
public function purge(): void
112-
{
113-
try {
114-
$this->connection->purgeQueues();
115-
} catch (\AMQPException $exception) {
116-
throw new TransportException($exception->getMessage(), 0, $exception);
117-
}
118-
}
119-
120108
/**
121109
* {@inheritdoc}
122110
*/

‎src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpTransport.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/AmqpExt/AmqpTransport.php
-8Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -60,14 +60,6 @@ public function reject(Envelope $envelope): void
6060
($this->receiver ?? $this->getReceiver())->reject($envelope);
6161
}
6262

63-
/**
64-
* {@inheritdoc}
65-
*/
66-
public function purge(): void
67-
{
68-
($this->receiver ?? $this->getReceiver())->purge();
69-
}
70-
7163
/**
7264
* {@inheritdoc}
7365
*/

‎src/Symfony/Component/Messenger/Transport/Doctrine/Connection.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/Doctrine/Connection.php
-15Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -196,21 +196,6 @@ public function setup(): void
196196
$this->schemaSynchronizer->updateSchema($this->getSchema(), true);
197197
}
198198

199-
public function purge(): void
200-
{
201-
$queryBuilder = $this->driverConnection->createQueryBuilder()
202-
->andWhere('queue_name = :queue_name')
203-
->delete($this->configuration['table_name']);
204-
205-
try {
206-
$this->executeQuery($queryBuilder->getSQL(), [
207-
'queue_name' => $this->configuration['queue_name'],
208-
]);
209-
} catch (DBALException $exception) {
210-
throw new TransportException($exception->getMessage(), 0, $exception);
211-
}
212-
}
213-
214199
public function getMessageCount(): int
215200
{
216201
$queryBuilder = $this->createAvailableMessagesQueryBuilder()

‎src/Symfony/Component/Messenger/Transport/Doctrine/DoctrineReceiver.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/Doctrine/DoctrineReceiver.php
-12Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -80,18 +80,6 @@ public function reject(Envelope $envelope): void
8080
}
8181
}
8282

83-
/**
84-
* {@inheritdoc}
85-
*/
86-
public function purge(): void
87-
{
88-
try {
89-
$this->connection->purge();
90-
} catch (DBALException $exception) {
91-
throw new TransportException($exception->getMessage(), 0, $exception);
92-
}
93-
}
94-
9583
/**
9684
* {@inheritdoc}
9785
*/

‎src/Symfony/Component/Messenger/Transport/Doctrine/DoctrineTransport.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/Doctrine/DoctrineTransport.php
-8Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -60,14 +60,6 @@ public function reject(Envelope $envelope): void
6060
($this->receiver ?? $this->getReceiver())->reject($envelope);
6161
}
6262

63-
/**
64-
* {@inheritdoc}
65-
*/
66-
public function purge(): void
67-
{
68-
($this->receiver ?? $this->getReceiver())->purge();
69-
}
70-
7163
/**
7264
* {@inheritdoc}
7365
*/

‎src/Symfony/Component/Messenger/Transport/InMemoryTransport.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/InMemoryTransport.php
-8Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -62,14 +62,6 @@ public function reject(Envelope $envelope): void
6262
$this->rejected[] = $envelope;
6363
}
6464

65-
/**
66-
* {@inheritdoc}
67-
*/
68-
public function purge(): void
69-
{
70-
$this->sent = [];
71-
}
72-
7365
/**
7466
* {@inheritdoc}
7567
*/

‎src/Symfony/Component/Messenger/Transport/Receiver/ReceiverInterface.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/Receiver/ReceiverInterface.php
-5Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -58,9 +58,4 @@ public function ack(Envelope $envelope): void;
5858
* @throws TransportException If there is an issue communicating with the transport
5959
*/
6060
public function reject(Envelope $envelope): void;
61-
62-
/**
63-
* Remove all messages waiting to be received.
64-
*/
65-
public function purge(): void;
6661
}

‎src/Symfony/Component/Messenger/Transport/Receiver/SingleMessageReceiver.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/Receiver/SingleMessageReceiver.php
-5Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -43,9 +43,4 @@ public function reject(Envelope $envelope): void
4343
{
4444
$this->receiver->reject($envelope);
4545
}
46-
47-
public function purge(): void
48-
{
49-
$this->receiver->purge();
50-
}
5146
}

‎src/Symfony/Component/Messenger/Transport/Sync/SyncTransport.php

Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Transport/Sync/SyncTransport.php
-5Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -45,11 +45,6 @@ public function reject(Envelope $envelope): void
4545
throw new InvalidArgumentException('You cannot call reject() on the SyncTransport.');
4646
}
4747

48-
public function purge(): void
49-
{
50-
throw new InvalidArgumentException('You cannot call purge() on the SyncTransport.');
51-
}
52-
5348
public function send(Envelope $envelope): Envelope
5449
{
5550
return $envelope->with(new ForceCallHandlersStamp());

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.