Merge pull request #117 from kaytu-io/fix-query-map-param

fix: add delete message to jq
opengovern · Sep 13, 2024 · fff8217 · fff8217
2 parents 8c4a455 + 74484f1
commit fff8217
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/pkg/jq/nats.go b/pkg/jq/nats.go
@@ -147,3 +147,15 @@ func (jq *JobQueue) Produce(ctx context.Context, topic string, data []byte, id s
 
 	return &pubAck.Sequence, nil
 }
+
+func (jq *JobQueue) DeleteMessage(ctx context.Context, streamName string, sequenceNumber uint64) error {
+	stream, err := jq.js.Stream(ctx, streamName)
+	if err != nil {
+		return err
+	}
+	err = stream.DeleteMsg(ctx, sequenceNumber)
+	if err != nil {
+		return err
+	}
+	return nil
+}