diff --git a/src/Verify.Wolverine/Converters/DestinationEndpoint.cs b/src/Verify.Wolverine/Converters/DestinationEndpoint.cs index 96e5a1f..28d3c3c 100644 --- a/src/Verify.Wolverine/Converters/DestinationEndpoint.cs +++ b/src/Verify.Wolverine/Converters/DestinationEndpoint.cs @@ -19,6 +19,16 @@ public Task InvokeAsync(object message, Cancel cancel = default, TimeSpan? where T : class => context.AddInvoke(message, timeout, EndpointName); + public Task InvokeAsync(object message, DeliveryOptions options, Cancel cancel = default, TimeSpan? timeout = null) + { + context.AddInvoke(message, timeout, EndpointName); + return Task.FromResult(new Acknowledgement()); + } + + public Task InvokeAsync(object message, DeliveryOptions options, Cancel cancel = default, TimeSpan? timeout = null) + where T : class => + context.AddInvoke(message, timeout, EndpointName); + public ValueTask SendRawMessageAsync(byte[] data, Type? messageType = null, Action? customize = null) => ValueTask.CompletedTask; diff --git a/src/Verify.Wolverine/Converters/RecordingMessageContext.cs b/src/Verify.Wolverine/Converters/RecordingMessageContext.cs index 1367d52..094a365 100644 --- a/src/Verify.Wolverine/Converters/RecordingMessageContext.cs +++ b/src/Verify.Wolverine/Converters/RecordingMessageContext.cs @@ -19,4 +19,5 @@ public RecordingMessageContext(object? message = null, PreviewSubscription? prev public string? CorrelationId { get; set; } public Envelope? Envelope { get; } public string? TenantId { get; set; } + public string? UserName { get; set; } }