diff --git a/internal/service/platformevents/builder.go b/internal/service/platformevents/builder.go index 1fc269e..97734bd 100644 --- a/internal/service/platformevents/builder.go +++ b/internal/service/platformevents/builder.go @@ -34,7 +34,7 @@ func BuildInboundEvents(msg *message.UnifiedMessage, result *dialog.Result, meta } eventIndex := 0 baseEvent := func(eventType string, payload map[string]any) platformevent.Event { - eventTime := now.Add(time.Duration(eventIndex) * time.Nanosecond) + eventTime := now.Add(time.Duration(eventIndex) * time.Millisecond) eventIndex++ return platformevent.Event{ ID: uuid.New().String(), @@ -47,7 +47,7 @@ func BuildInboundEvents(msg *message.UnifiedMessage, result *dialog.Result, meta Payload: payload, Status: platformevent.StatusPending, AttemptCount: 0, - NextAttemptAt: eventTime, + NextAttemptAt: now, OccurredAt: eventTime, CreatedAt: eventTime, UpdatedAt: eventTime,