use Symfony\Component\Messenger\Stamp\SentToFailureTransportStamp;
use Symfony\Component\Messenger\Tests\Fixtures\DummyMessage;
use Symfony\Component\Messenger\Transport\Receiver\ReceiverInterface;
use Symfony\Component\Messenger\Transport\Sender\SenderInterface;
use Symfony\Component\Messenger\Transport\Sender\SendersLocator;
use Symfony\Component\Messenger\Worker;
class FailureIntegrationTest extends TestCase
{ public function testRequeueMechanism() { $transport1 =
new DummyFailureTestSenderAndReceiver();
$transport2 =
new DummyFailureTestSenderAndReceiver();
$failureTransport =
new DummyFailureTestSenderAndReceiver();
$sendersLocatorFailureTransport =
new ServiceLocator([ 'transport1' =>
fn () =>
$failureTransport,
'transport2' =>
fn () =>
$failureTransport,
]);
$transports =
[ 'transport1' =>
$transport1,
'transport2' =>
$transport2,
'the_failure_transport' =>
$failureTransport,
];