Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: refactor RocketMQ bridge to connector and action #12488

Conversation

kjellwinblad
Copy link
Contributor

@kjellwinblad kjellwinblad commented Feb 7, 2024

Fixes:
https://emqx.atlassian.net/browse/EMQX-11467

Release version: v/e5.?

Summary

PR Checklist

Please convert it to a draft if any of the following conditions are not met. Reviewers may skip over until all the items are checked:

  • Added tests for the changes
  • [] Added property-based tests for code which performs user input validation
  • [] Changed lines covered in coverage report
  • Change log has been added to changes/(ce|ee)/(feat|perf|fix|breaking)-<PR-id>.en.md files
  • For internal contributor: there is a jira ticket to track this change
  • [] Created PR to emqx-docs if documentation update is required, or link to a follow-up jira ticket
  • Schema changes are backward compatible

@kjellwinblad kjellwinblad force-pushed the kjell/refactor/rocketmq_bridge/EMQX-11467 branch 2 times, most recently from a3c3310 to e284a83 Compare February 8, 2024 15:20
@kjellwinblad kjellwinblad marked this pull request as ready for review February 8, 2024 16:48
@kjellwinblad kjellwinblad requested review from JimMoen and a team as code owners February 8, 2024 16:48
thalesmg
thalesmg previously approved these changes Feb 9, 2024
Copy link
Contributor

@thalesmg thalesmg left a comment

Choose a reason for hiding this comment

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

Nit: might be good to have some smoke tests that go through the v2 APIs and schemas (like the ones in emqx_bridge_v2_testlib).

apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq.erl Outdated Show resolved Hide resolved
apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq.erl Outdated Show resolved Hide resolved
@kjellwinblad
Copy link
Contributor Author

Thanks @thalesmg for a good review. I fixed the issues that you pointed out.

@kjellwinblad
Copy link
Contributor Author

Nit: might be good to have some smoke tests that go through the v2 APIs and schemas (like the ones in emqx_bridge_v2_testlib).

Thanks. I will have a look at emqx_bridge_v2_testlib. If we add such tests I think we can do it in another PR so we can get this merged.

@kjellwinblad kjellwinblad merged commit 3668273 into emqx:master Feb 13, 2024
165 checks passed
Comment on lines +178 to +183
on_get_channel_status(
_ResId,
_ChannelId,
_State
) ->
?status_connected.
Copy link
Member

Choose a reason for hiding this comment

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

check channel ID exist.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

4 participants