[FEATURE] Can aop natively support delay message feature based on Pulsar ？

Open
#321 4 comments 1 reaction 0 assignees View on GitHub

Nobody has claimed this yet.

Assessment

Difficulty
5/5
Estimated time
Over a week
Newbie friendliness
35/100
Issue type
Feature
Clarity
Mostly clear
Activity status
Stale
Tech stack
java
Domain
distributed-systems

Research direction

Start by tracing how AMQP.BasicProperties headers are handled and review Pulsar's native delayed-message support. The requested behavior is to parse a delay header and set the message delivery time; done means AMQP messages with that header are delivered according to the requested delay.

Written by the indexing model from the issue text.

Description

type/feature

Pulsar has native support for delay message. Can aop support this based on Pulsar too？

For example, by parsing the delay field in the header, you can set the delivery time of the message.

Map<String, Object> headers = new HashMap<>();
headers.put("delay", "xx");
AMQP.BasicProperties props = new AMQP.BasicProperties.Builder().messageId(UUID.randomUUID().toString()).headers(headers).build();
Dominant language
Java
Stars
123
Forks
41
Avg merge
4h 43m
Merged PRs (30d)
4

Contributor guide

No contributing guide indexed for this repository

First steps

  1. Read the whole issue, then the project's contributing guide.
  2. Comment on the issue to say you are picking it up — it saves two people doing the same work.
  3. Fork the repository and make your change on a branch.
  4. Open a pull request that references the issue number.

More from streamnative/aop

All issues in streamnative/aop

Similar issues

More Java issues

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.