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

Async consumers for multiprocessing #2

Merged
merged 4 commits into from
Dec 8, 2021
Merged

Conversation

adam-vessey
Copy link

Also, bit of formatting of the markdown.


... I need some more complex images to OCR, to be able to see multiple threads... or to slap in JP2 encoding or something that takes longer in terms of a derivative to see multiple convert instances running at a time...

@adam-vessey adam-vessey marked this pull request as ready for review December 7, 2021 19:59
For example, with two services defined (houdini and crayfits) my configuration would have

```
derivative.systems.installed=houdini,fits

Copy link
Owner

Choose a reason for hiding this comment

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

This is a total nit-pick but could you add

derivative.houdini.async-consumer=true

below as that one has different values for concurrent-consumers and max-concurrent-consumers.

Otherwise, I'm good with this.

Copy link
Author

Choose a reason for hiding this comment

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

Heh... could do: Didn't really want to touch the example stuff where it says "[your] configuration would have [these things]"...

@whikloj whikloj merged commit a57a2dc into whikloj:one-app Dec 8, 2021
whikloj added a commit that referenced this pull request Dec 10, 2021
* Make a single jar with configurable services

* Add example properties

* Remove old property files, fix license on classes copied from Fedora

* More fixes to README

* Fixes from tests not working

* Logging for custom http client settings

* Alter README

* Alter Github Actions to use Java 11

* Make concurrent consumers configurable per service

* Add disableStreamCache=true option to http calls

* Switch back to using toD with full URL

* Missed clean-up

* Fix PMD rule violations

* Fix GH actions for different branches

* Ignore 2 PMD rules in specific cases

* Correctly reference the exchange

* Move to inject the CamelContext (#1)

* Change up instantiation/initialization slightly.

* PostConstruct is allowed to apply to private methods...

... seems like a false-positive in PMD? Got example exception from:
https://stackoverflow.com/a/48679770

* Changing to camel's 3.7.6 LTS.

* Async consumers for multiprocessing (#2)

* Fix up warning about the unclosed app context.

* Slap together async-consumer stuff.

* Add separator for asyncConsumer parameter.

* Update example as suggested.

* Code review

Co-authored-by: Adam <adam-vessey@users.noreply.github.com>
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.

2 participants