diff --git a/src/NServiceBus.Transport.SqlServer/Queuing/SqlConstants.cs b/src/NServiceBus.Transport.SqlServer/Queuing/SqlConstants.cs index 50af2e5ca..666bea794 100644 --- a/src/NServiceBus.Transport.SqlServer/Queuing/SqlConstants.cs +++ b/src/NServiceBus.Transport.SqlServer/Queuing/SqlConstants.cs @@ -114,7 +114,7 @@ DELETE FROM message NULL, deleted.Headers, deleted.Body -INTO {1}; +INTO {1} (Id, CorrelationId, ReplyToAddress, Recoverable, Expires, Headers, Body); SELECT TOP 1 GETUTCDATE() as UtcNow, Due as NextDue FROM {0} WITH (READPAST)