diff --git a/src/core/Elsa.Core/ServiceBusOptions.cs b/src/core/Elsa.Core/ServiceBusOptions.cs
index ad029a348..9a42eaa57 100644
--- a/src/core/Elsa.Core/ServiceBusOptions.cs
+++ b/src/core/Elsa.Core/ServiceBusOptions.cs
@@ -6,6 +6,7 @@ namespace Elsa
     {
         public int? NumberOfWorkers { get; set; }
         public int? MaxParallelism { get; set; }
+        public string? QueuePrefix { get; set; }
 
         public void Apply(OptionsConfigurer configurer)
         {
diff --git a/src/core/Elsa.Core/Services/ServiceBusFactory.cs b/src/core/Elsa.Core/Services/ServiceBusFactory.cs
index d46f9f9ba..c47efd955 100644
--- a/src/core/Elsa.Core/Services/ServiceBusFactory.cs
+++ b/src/core/Elsa.Core/Services/ServiceBusFactory.cs
@@ -25,7 +25,7 @@ namespace Elsa.Services
 
         public async Task<IBus> GetServiceBusAsync(Type messageType, CancellationToken cancellationToken)
         {
-            var queueName = messageType.Name;
+            var queueName = FormatQueueName(messageType.Name);
             await _semaphore.WaitAsync(cancellationToken);
             
             try
@@ -49,5 +49,7 @@ namespace Elsa.Services
                 _semaphore.Release();
             }
         }
+
+        private string FormatQueueName(string name) => $"{_elsaOptions.ServiceBusOptions.QueuePrefix}{name}";
     }
 }
\ No newline at end of file