-
Notifications
You must be signed in to change notification settings - Fork 261
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
sendEvents Async #7138
sendEvents Async #7138
Conversation
…eadPool to not spawn a lot of threads that do small work. Reworked the OMRSTopic interface to support async send, made minimal changes (sendInstance event is not checked, but it could be changed for consistency) Signed-off-by: marius-patrascu <[email protected]>
...ta/repositoryservices/connectors/openmetadatatopic/OpenMetadataTopicSenderConnectorBase.java
Outdated
Show resolved
Hide resolved
Signed-off-by: marius-patrascu <[email protected]>
...ta/repositoryservices/connectors/openmetadatatopic/OpenMetadataTopicSenderConnectorBase.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
approve. please check minor comments
...n/java/org/odpi/openmetadata/repositoryservices/connectors/omrstopic/OMRSTopicConnector.java
Outdated
Show resolved
Hide resolved
...n/java/org/odpi/openmetadata/repositoryservices/connectors/omrstopic/OMRSTopicConnector.java
Outdated
Show resolved
Hide resolved
...ta/repositoryservices/connectors/openmetadatatopic/OpenMetadataTopicSenderConnectorBase.java
Outdated
Show resolved
Hide resolved
Signed-off-by: marius-patrascu <[email protected]>
Signed-off-by: marius-patrascu <[email protected]>
...ta/repositoryservices/connectors/openmetadatatopic/OpenMetadataTopicSenderConnectorBase.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Disregard the previous error, it was related wrong configuration.
This change however introduces regression, registry events do not get sent. Blocking the PR, needs more work.
Signed-off-by: marius-patrascu <[email protected]>
Signed-off-by: marius-patrascu <[email protected]>
...n/java/org/odpi/openmetadata/repositoryservices/connectors/omrstopic/OMRSTopicConnector.java
Show resolved
Hide resolved
...n/java/org/odpi/openmetadata/repositoryservices/connectors/omrstopic/OMRSTopicConnector.java
Show resolved
Hide resolved
...n/java/org/odpi/openmetadata/repositoryservices/connectors/omrstopic/OMRSTopicConnector.java
Show resolved
Hide resolved
...n/java/org/odpi/openmetadata/repositoryservices/connectors/omrstopic/OMRSTopicConnector.java
Show resolved
Hide resolved
...n/java/org/odpi/openmetadata/repositoryservices/connectors/omrstopic/OMRSTopicConnector.java
Show resolved
Hide resolved
🛠 Lift Auto-fixSome of the Lift findings in this PR can be automatically fixed. You can download and apply these changes in your local project directory of your branch to review the suggestions before committing.1 # Download the patch
curl https://lift.sonatype.com/api/patch/github.com/odpi/egeria/7138.diff -o lift-autofixes.diff
# Apply the patch with git
git apply lift-autofixes.diff
# Review the changes
git diff Want it all in a single command? Open a terminal in your project's directory and copy and paste the following command: curl https://lift.sonatype.com/api/patch/github.com/odpi/egeria/7138.diff | git apply Once you're satisfied commit and push your changes in your project. Footnotes |
This change was functionally tested and validated. No functional regression found.
|
Signed-off-by: marius-patrascu [email protected]
Description
Send instance, types, registrations events async. Use the default threadPool to not spawn a lot of threads that do small work. Reworked the OMRSTopic interface to support async send, made minimal changes (sendInstance event is not checked, but it could be changed for consistency)
Testing
Build, UT, FVT, UI, manual