Skip to content

Context Aware MQ #35

Description

@taitelee

Problem

The Ack() and Nak() methods in our message queue implementation currently lack context.Context. This means they cannot respect request timeouts or graceful shutdown signals, potentially leading to "hanging" operations if the connection to NATS is interrupted.

Proposed Solution

Refactor the mq interface to include ctx context.Context in all acknowledgment methods. This ensures that every interaction with the message broker is bound by the application's lifecycle and timeout policies.

Taite can take this

Alternatives Considered

None

Additional Context

None

Metadata

Metadata

Assignees

Labels

area/ingestIngest pipeline (Bento, batching, DLQ)breaking-changeBreaking change to public API, CLI, or configenhancementNew feature or request

Projects

Status
Done

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions