diff --git a/src/NServiceBus.Transport.SqlServer/Queuing/SqlServerConstants.cs b/src/NServiceBus.Transport.SqlServer/Queuing/SqlServerConstants.cs index 370be340b..468dcf74a 100644 --- a/src/NServiceBus.Transport.SqlServer/Queuing/SqlServerConstants.cs +++ b/src/NServiceBus.Transport.SqlServer/Queuing/SqlServerConstants.cs @@ -52,7 +52,7 @@ THEN DATEADD(ms, @TimeToBeReceivedMs, GETUTCDATE()) END, public string CheckIfTableHasRecoverableText { get; set; } = @" SELECT COUNT(*) -FROM {0}.sys.columns c +FROM [{0}].sys.columns c WHERE c.object_id = OBJECT_ID(N'{1}') AND c.name = 'Recoverable'";