commercetools / commercetools/fs2-queues

Add support for delayed messages stats in gcp pubsub

Open
#58 0 comments 0 reactions 0 assignees View on GitHub
good first issue pubsub
Dominant language
Scala
Stars
17
Forks
3
PR merge metrics
No merged PRs in 30d

Description

Context: in pubsub the notion of delayed message is not natively supported, so the lib is emulating by setting a [custom attribute and having a dedicated behavior](https://github.com/commercetools/fs2-queues/blob/main/gcp/pubsub/src/main/scala/com/commercetools/queue/gcp/pubsub/PubSubPuller.scala#L63-L72) in how it pushes and receives messages.

Since this part in under our control, we can maybe think of ways of exposing an approximation of how many messages are currently delayed. An idea: counting how many messages bring that specific custom attribute.

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.