fix delay header

bottledcode · Mar 11, 2024 · fce454a · fce454a
1 parent a4faaa1
commit fce454a
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 2 deletions.
diff --git a/bin/dphp-linux-x86_64 b/bin/dphp-linux-x86_64
diff --git a/cli/lib/consumer.go b/cli/lib/consumer.go
@@ -42,7 +42,7 @@ func BuildConsumer(stream jetstream.Stream, ctx context.Context, streamName stri
 			meta, _ := msg.Metadata()
 			headers := msg.Headers()
 
-			if headers.Get("Delay") != "" && meta.NumDelivered == 1 {
+			if headers.Get(string(HeaderDelay)) != "" && meta.NumDelivered == 1 {
 				logger.Debug("Delaying message", zap.String("delay", msg.Headers().Get("Delay")), zap.Any("Headers", meta))
 				schedule, err := time.Parse(time.RFC3339, msg.Headers().Get("Delay"))
 				if err != nil {

diff --git a/cli/lib/response_writer.go b/cli/lib/response_writer.go
@@ -78,7 +78,7 @@ func (w *InternalLoggingResponseWriter) Write(b []byte) (int, error) {
 			}
 
 			if body.ScheduleAt.After(time.Now()) {
-				msg.Header.Add(string(HeaderDelay), body.ScheduleAt.String())
+				msg.Header.Add(string(HeaderDelay), body.ScheduleAt.Format(time.RFC3339))
 			}
 
 			w.events = append(w.events, msg)