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

[Richard-Yi]

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();

[gaoran10]

Yes, I think we could support the delay message feature in AoP based on the Pulsar.

[gaoran10]

@Richard-Yi Are you interested to work on this feature?

[Richard-Yi]

@gaoran10 Yes, I'm interested. I'll be working on this feature. But I'm a newbie at github contribution, do i just follow the contribution workflow in README?

[gaoran10]

Sure, you could fork this repo and pull a new request for the delay message feature.