diff --git a/src/Wolverine/Runtime/Handlers/Executor.cs b/src/Wolverine/Runtime/Handlers/Executor.cs
index 11f7fb698..06f07fdb7 100644
--- a/src/Wolverine/Runtime/Handlers/Executor.cs
+++ b/src/Wolverine/Runtime/Handlers/Executor.cs
@@ -95,6 +95,7 @@ public async Task InvokeInlineAsync(Envelope envelope, CancellationToken cancell
         using var activity = Handler.TelemetryEnabled ? WolverineTracing.StartExecuting(envelope) : null;
 
         _tracker.ExecutionStarted(envelope);
+        _executionStarted(_logger, envelope!.CorrelationId!, _messageTypeName, envelope.Id, null);
 
         var context = _contextPool.Get();
         context.ReadEnvelope(envelope, InvocationCallback.Instance);
@@ -111,11 +112,13 @@ public async Task InvokeInlineAsync(Envelope envelope, CancellationToken cancell
             await context.FlushOutgoingMessagesAsync();
             activity?.SetStatus(ActivityStatusCode.Ok);
             _tracker.ExecutionFinished(envelope);
+            _messageSucceeded(_logger, _messageTypeName, envelope.Id,  envelope.Destination!.ToString(), null);
         }
         catch (Exception e)
         {
             activity?.SetStatus(ActivityStatusCode.Error, e.GetType().Name);
             _tracker.ExecutionFinished(envelope, e);
+            _messageFailed(_logger, _messageTypeName, envelope.Id, envelope.Destination!.ToString(), e);
             throw;
         }
         finally