diff --git a/src/NServiceBus.IntegrationTesting/MessageSessionExtensions.cs b/src/NServiceBus.IntegrationTesting/MessageSessionExtensions.cs new file mode 100644 index 00000000..57ae3b03 --- /dev/null +++ b/src/NServiceBus.IntegrationTesting/MessageSessionExtensions.cs @@ -0,0 +1,18 @@ +using System.Threading.Tasks; + +namespace NServiceBus.IntegrationTesting +{ + public static class MessageSessionExtensions + { + public static Task TriggerTimeoutFor(this IMessageSession messageSession, string destinationEndpointName, string sagaUniqueIdentifier, object timeoutInstance) + { + var sendOptions = new SendOptions(); + sendOptions.SetDestination(destinationEndpointName); + sendOptions.SetHeader(Headers.SagaType, typeof(TSaga).AssemblyQualifiedName); + sendOptions.SetHeader(Headers.IsSagaTimeoutMessage, bool.TrueString); + sendOptions.SetHeader(Headers.SagaId, sagaUniqueIdentifier); + + return messageSession.Send(timeoutInstance, sendOptions); + } + } +}