diff --git a/src/KafkaFlow.Retry.SqlServer/Repositories/RetryQueueItemMessageRepository.cs b/src/KafkaFlow.Retry.SqlServer/Repositories/RetryQueueItemMessageRepository.cs
index 521c09a5..49db4a8e 100644
--- a/src/KafkaFlow.Retry.SqlServer/Repositories/RetryQueueItemMessageRepository.cs
+++ b/src/KafkaFlow.Retry.SqlServer/Repositories/RetryQueueItemMessageRepository.cs
@@ -50,7 +50,7 @@ public async Task<IList<RetryQueueItemMessageDbo>> GetMessagesOrderedAsync(IDbCo
                 }
                 var parameter = new SqlParameter("@RetryQueueItemsIds", entriesToLoad);
                 parameter.Direction = System.Data.ParameterDirection.Input;
-                parameter.TypeName = "dbo.TY_RetryQueueItemsIds";
+                parameter.TypeName = "TY_RetryQueueItemsIds";
 
                 command.Parameters.Add(parameter);
                 command.CommandType = System.Data.CommandType.Text;