diff --git a/config/packages/messenger.yaml b/config/packages/messenger.yaml
index bff1748..a4843b2 100644
--- a/config/packages/messenger.yaml
+++ b/config/packages/messenger.yaml
@@ -9,7 +9,7 @@ framework:
                 retry_strategy:
                     max_retries: 3
                     multiplier: 2
-            rdap_async:
+            rdap_high:
                 dsn: '%env(MESSENGER_RDAP_ASYNC_TRANSPORT_DSN)%'
                 options:
                     consumer: '%env(MESSENGER_CONSUMER_NAME)%'
@@ -18,6 +18,15 @@ framework:
                     multiplier: 2
                     max_delay: 86400000
 
+            rdap_low:
+                dsn: '%env(MESSENGER_RDAP_ASYNC_TRANSPORT_DSN)%'
+                options:
+                    consumer: '%env(MESSENGER_CONSUMER_NAME)%'
+                retry_strategy:
+                    delay: 2000
+                    multiplier: 2
+                    max_delay: 86400000
+
             failed: 'doctrine://default?queue_name=failed'
             # sync: 'sync://'
 
@@ -37,4 +46,4 @@ framework:
             App\Message\ProcessWatchlist: async
             App\Message\UpdateRdapServers: async
             App\Message\ValidateConnectorCredentials: async
-            App\Message\UpdateDomain: rdap_async
+            App\Message\UpdateDomain: rdap_high
diff --git a/src/Command/BatchRegisterDomainCommand.php b/src/Command/BatchRegisterDomainCommand.php
index b86a8dd..9b4f03d 100644
--- a/src/Command/BatchRegisterDomainCommand.php
+++ b/src/Command/BatchRegisterDomainCommand.php
@@ -11,6 +11,7 @@ use Symfony\Component\Console\Output\OutputInterface;
 use Symfony\Component\Console\Style\SymfonyStyle;
 use Symfony\Component\Messenger\Exception\ExceptionInterface;
 use Symfony\Component\Messenger\MessageBusInterface;
+use Symfony\Component\Messenger\Stamp\TransportNamesStamp;
 
 #[AsCommand(
     name: 'app:batch-register-domains',
@@ -54,7 +55,9 @@ class BatchRegisterDomainCommand extends Command
         $io->title('Registering domains');
         /** @var string $ldhName */
         foreach ($domains as $ldhName) {
-            $this->messageBus->dispatch(new UpdateDomain($ldhName, null));
+            $this->messageBus->dispatch(new UpdateDomain($ldhName, null), [
+                new TransportNamesStamp('rdap_low'),
+            ]);
         }
 
         $io->success(sprintf('Imported %d domain names.', count($domains)));