diff --git a/internal/eventstore/v3/push_test.go b/internal/eventstore/v3/push_test.go
index 50f771b54..26905ffb8 100644
--- a/internal/eventstore/v3/push_test.go
+++ b/internal/eventstore/v3/push_test.go
@@ -262,8 +262,8 @@ func Test_mapCommands(t *testing.T) {
 
 func TestEventstore_queueExecutions(t *testing.T) {
 	events := []eventstore.Event{
-		mockEventType(mockAggregate("TEST"), 1, nil, "ex.foo.bar"),
-		mockEventType(mockAggregate("TEST"), 2, nil, "ex.bar.foo"),
+		mockEventType(mockAggregate("TEST"), 1, []byte(`{"test":"test"}`), "ex.foo.bar"),
+		mockEventType(mockAggregate("TEST"), 2, []byte("{}"), "ex.bar.foo"),
 		mockEventType(mockAggregate("TEST"), 3, nil, "ex.removed"),
 	}
 	type args struct {
diff --git a/internal/repository/execution/queue.go b/internal/repository/execution/queue.go
index 7cce61b06..bf819fcd6 100644
--- a/internal/repository/execution/queue.go
+++ b/internal/repository/execution/queue.go
@@ -27,10 +27,13 @@ func NewRequest(e eventstore.Event, targets []target.Target) (*Request, error) {
 	if err != nil {
 		return nil, err
 	}
-	eventData, err := json.Marshal(e)
+	// The underlying BaseEvent omits the data when using json.Marshal so we have to unmarshal it manually.
+	var eventData json.RawMessage
+	err = e.Unmarshal(&eventData)
 	if err != nil {
 		return nil, err
 	}
+
 	return &Request{
 		Aggregate:   e.Aggregate(),
 		Sequence:    e.Sequence(),