Subscribing queues to topics

[eladb]

Use Case

I'd like to be able to have send notifications sent to a cloud.Topic into a cloud.Queue for processing.

Proposed Solution

Something like this:

bring cloud;

let q = new cloud.Queue();
let t = new cloud.Topic();
t.subscribeQueue(q);

Implementation Notes

In AWS, it is possible to connect SNS to SQS directly.

Component

No response

Community Notes

• Please vote by adding a 👍 reaction to the issue to help us prioritize.
• If you are interested to work on this issue, please leave a comment.
• If this issue is labeled needs-discussion, it means the spec has not been finalized yet. Please reach out on the #dev channel in the Wing Slack.

[ekeren]

@eladb it seems pretty straightforward, can you elaborate why you added the needs-discussion label?

[eladb]

It was automatically added

[marciocadev]

Guys, this is basically what I did in messagefanout

https://github.com/winglang/winglibs/tree/main/messagefanout

bring messagefanout;

let fanout = new messagefanout.MessageFanout();

fanout.addConsumer(inflight (msg: str) => {
  log("Hello {msg}!!!");
});

test "push a message to fanout" {
  fanout.publish("world");
}

[eladb]

Very cool @marciocadev - based on feedback from users we see this as something that can be incorporated into the standard library.

Would you like to work on this?

[marciocadev]

Yes, I can do it ☺️

[marciocadev]

I started implementing in the simulator, which is always the hardest part for me, but I think visually it turned out pretty cool.
I created the queueSubscription method, if you think it should be named differently, let me know.

bring cloud;

let t = new cloud.Topic();

let q1 = new cloud.Queue() as "q1";
t.queueSubscription(q1);
q1.setConsumer(inflight (msg: str) => {
  log("from topic to queue 1: {msg}");
});

let q2 = new cloud.Queue() as "q2";
t.queueSubscription(q2);
q2.setConsumer(inflight (msg: str) => {
  log("from topic to queue 2: {msg}");
});

t.onMessage(inflight (msg: str) => {
  log("from topic: {msg}");
});

[marciocadev]

Now I see, I will change to subscribeQueue

[monadabot]

Congrats! 🚀 This was released in Wing 0.67.12.