diff --git a/src/NServiceBus.Transport.SqlServer/Queuing/SqlConstants.cs b/src/NServiceBus.Transport.SqlServer/Queuing/SqlConstants.cs index a2393caf1..9b62c4039 100644 --- a/src/NServiceBus.Transport.SqlServer/Queuing/SqlConstants.cs +++ b/src/NServiceBus.Transport.SqlServer/Queuing/SqlConstants.cs @@ -97,7 +97,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)