Skip to content
This repository has been archived by the owner on Apr 11, 2024. It is now read-only.

feat: use watermill as routing framework #52

Merged
merged 7 commits into from
Oct 4, 2021

Conversation

smoya
Copy link
Collaborator

@smoya smoya commented Sep 29, 2021

Description

This resolves #43.

TL;DR: this sets the base for routing messages by using Watermill.io framework.

Using Watermill.io will reduce the complexity of the code, simplify the routing and message handling and reduce the time spent on all those efforts. Even though more work will be needed around app configuration, things like #37 have become now more trivial; adding a new handler to the Watermill router will subscribe to incoming Kafka messages and send them to a Kafka topic. Adding a second handler, those will be consumed by a process that will send them to the websocket clients.

I'm pretty excited for the simplicity of Watermill.io framework and how it simplifies most of the operation.

Related issue(s)
#43

@smoya smoya added the enhancement New feature or request label Sep 29, 2021
Copy link
Collaborator

@magicmatatjahu magicmatatjahu left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Overall good, only two things, but not necessary :)

message/message.go Show resolved Hide resolved
kafka/proxy.go Outdated Show resolved Hide resolved
kafka/proxy.go Outdated Show resolved Hide resolved
@smoya smoya requested a review from magicmatatjahu October 4, 2021 11:05
Copy link
Collaborator

@magicmatatjahu magicmatatjahu left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@smoya smoya merged commit 64782cd into asyncapi-archived-repos:master Oct 4, 2021
@smoya smoya deleted the feat/watermill branch October 4, 2021 11:31
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
enhancement New feature or request
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Consider use of https://watermill.io for core routing and forwarding logic
3 participants