diff --git a/pkg/events/events.go b/pkg/events/events.go
index 9101a9236e3..2477bbef13e 100644
--- a/pkg/events/events.go
+++ b/pkg/events/events.go
@@ -32,7 +32,7 @@ type EventBase interface {
 }
 
 func ToOnWriteEvent(event interface{}) (*OnTheWireEvent, error) {
-	eventType := reflect.TypeOf(event)
+	eventType := reflect.TypeOf(event).Elem()
 
 	wireEvent := OnTheWireEvent{
 		Priority:  PRIO_INFO,
@@ -40,7 +40,7 @@ func ToOnWriteEvent(event interface{}) (*OnTheWireEvent, error) {
 		Payload:   event,
 	}
 
-	baseField := reflect.ValueOf(event).FieldByName("Timestamp")
+	baseField := reflect.Indirect(reflect.ValueOf(event)).FieldByName("Timestamp")
 	if baseField.IsValid() {
 		wireEvent.Timestamp = baseField.Interface().(time.Time)
 	} else {