CAMEL-7118: Hazelcast-based Recoverable Aggregation Repository #84
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
The new renameUsingCopy option controls whether rename operations are performed using a copy and delete strategy. This is primarily used in environments where the regular rename operation is unreliable (e.g. across different file systems and networks). Signed-off-by: Gregor Zurowski <gregor@zurowski.org>
Signed-off-by: Gregor Zurowski <gregor@zurowski.org>
Fixed broken build
Signed-off-by: Gregor Zurowski <gregor@zurowski.org>
Remove redundant version specification from dependencies that are already defined with the exact same version by their parents. Signed-off-by: Gregor Zurowski <gregor@zurowski.org>
Fix typo as requested by Bilgin Ibryam <bibryam@apache.org>. Signed-off-by: Gregor Zurowski <gregor@zurowski.org>
…/alexlomov/camel into hazelcast-aggregation-repository Merge after rebase
|
what version of Camel does include this PR? |
|
As far as I know it's target version is 2.14. |
|
I wonder if it makes sense to write something by hands, or somehow backport this code into project with camel 2.12.x (or 2.13.x). |
|
I use a custom camel-hazelcast build of 2.13.1 version. The code merges well. |
onderson
pushed a commit
to onderson/camel
that referenced
this pull request
Aug 25, 2017
# The first commit's message is: Unable to change DataFormat.contentTypeHeader value to false JaxbDataFormat has a contentTypeHeader property with default value of TRUE. It should be able to change contentTypeHeader to FALSE. # This is the commit message #2: Improve SupervisingRouteController # This is the commit message #3: Refactor BackOff timer # This is the commit message apache#4: Upgrade Jgroups to version 4.0.5.Final # This is the commit message apache#5: CAMEL-11657 - Camel-spring-security: The Karaf feature need spring-security-config to be installed # This is the commit message apache#6: Upgrade Hazelcast to version 3.8.4 # This is the commit message apache#7: Changed S3Producer to use S3Constants.S3_OPERATION instead of EC2Constants.OPERATION # This is the commit message apache#8: Import of the IEC 60870 component This change adds an IEC 60870 camel component based on the IEC 60870 implementation of Eclipse NeoSCADA. Signed-off-by: Jens Reimann <jreimann@redhat.com> # This is the commit message apache#9: Amend changes based on review. Signed-off-by: Jens Reimann <jreimann@redhat.com> # This is the commit message apache#10: Add the camel-iec60870 and camel-iec60870-starter This change adds the ne camel-iec6087 and camel-iec60870-starter modules to a few build files. Signed-off-by: Jens Reimann <jreimann@redhat.com> # This is the commit message apache#11: Regen # This is the commit message apache#12: Added camel-iec60870 to components POM # This is the commit message apache#13: Fix CS # This is the commit message apache#14: CAMEL-11659: Create a ClusteredRouteController # This is the commit message apache#15: ClusteredRouteController: use spring-boot to spin up the boostrap node # This is the commit message apache#16: fix using MasterComponent # This is the commit message apache#17: closing entity manager # This is the commit message apache#18: surrounded with try/catch/finally to ensure entity manager always closes # This is the commit message apache#19: CAMEL-11630: Fixed CS. This closes apache#1883. # This is the commit message apache#20: camel-bigquery: add initial version to endpoint annotations # This is the commit message apache#21: camel-bigquery: fix endpoint annotation # This is the commit message apache#22: Fixes Checkstyle issues in Salesforce component # This is the commit message apache#23: Code style: remove unused imports # This is the commit message apache#24: CAMEL-11668: CompositeApiClient class in the camel-salesforces component cannot close a null InputStream # This is the commit message apache#25: CAMEL-11561: Cleanup Salesforce integration tes... ...ts setup This removes unused profiles that might conflict when running the Ant Migration Tool and defines Connectec App OAuth Client Id and Client Secret from the `test-salesforce-login.properties`. So it is up to the user of the tests to pick a unique Client Id, i.e. simply by creating an Connected App and using those values and then deleting it. # This is the commit message apache#26: CAMEL-11668: CompositeApiClient class in the ca... ...mel-salesforces component cannot close a null InputStream Cleaned up to use `IOHelper.close` instead. # This is the commit message apache#27: CAMEL-11629: Cleanup SalesforceComponentVerifie... ...rTest Splits the SalesforceComponentVerifier test into integration (connectivity) and unit test (parameter). The integration test now relies on `LoginConfigHelper` that reads its configuration from `salesforce-test-login.properties`. # This is the commit message apache#28: Regen # This is the commit message apache#29: Polished summary of new component. # This is the commit message apache#30: Fix typo on rest endpoints # This is the commit message apache#31: CAMEL-11438 added javadoc to the endpoint class + test class polished # This is the commit message apache#32: regenerate camel-crypto-cms-starter # This is the commit message apache#33: CAMEL-11638: upgrade camel-ssh to use apache-sshd version 1.6.0 # This is the commit message apache#34: CAMEL-11638: upgrade camel-jsch to use apache-sshd version 1.6.0 # This is the commit message apache#35: CAMEL-11638: upgrade camel-ftp to use apache-sshd version 1.6.0 # This is the commit message apache#36: regenerate # This is the commit message apache#37: add camel-google-bigquery-starter to kit # This is the commit message apache#38: Upgrade hbase. This fixes apache#1896 # This is the commit message apache#39: CAMEL-11621: extend simple date formatter for properties # This is the commit message apache#40: Polished. This fixes apache#1890 # This is the commit message apache#41: [CAMEL-11688]ensure transport endpoint configuration will be take into account when create JettyRestHttpBinding from REST DSL # This is the commit message apache#42: Upgrade Caffeine to version 2.5.5 # This is the commit message apache#43: Upgrade Chronicle Core to version 1.9.3 # This is the commit message apache#44: Upgrade Chronicle Threads to version 1.8.2 # This is the commit message apache#45: Upgrade Chronicle Bytes to version 1.9.6 # This is the commit message apache#46: Upgrade Chornicle Network to version 1.9.2 # This is the commit message apache#47: Upgrade Chronicle Wire to version 1.9.10 # This is the commit message apache#48: CAMEL-11671 dont rebuild the request and respect url encoding of the original request # This is the commit message apache#49: Upgrade Spring Cloud Netflix to version 1.3.4.RELEASE # This is the commit message apache#50: CAMEL-11674 - Couchbase client is never shut down # This is the commit message apache#51: CAMEL-11316: Added support for HTTP OPTIONS in camel-restlet # This is the commit message apache#52: Fixed CS # This is the commit message apache#53: Upgrade Mybatis to version 3.4.5 # This is the commit message apache#54: CAMEL-11685 - Camel-Hazelcast: Add removeAll and removeIf to queue component # This is the commit message apache#55: CAMEL-11685 - Fixed docs # This is the commit message apache#56: Revert "CAMEL-11655 - Camel-Nagios: Use Encryption enum instead of EncryptionMethod" This reverts commit efee1f7. # This is the commit message apache#57: CAMEL-11665 - Camel-Nagios: Deprecate EncryptionMethod and use Encryption Enum # This is the commit message apache#58: CAMEL-11611 - Add a knownHosts option to the camel-ssh component # This is the commit message apache#59: CAMEL-11611 - Adjusted the code to reflect the use of Apache Sshd 1.6.0 # This is the commit message apache#60: CAMEL-11682: Add sasl.jaas.config setting # This is the commit message apache#61: CAMEL-11682 - Regen and docs # This is the commit message apache#62: CAMEL-11438 documentation improved # This is the commit message apache#63: CAMEL-11611: polish # This is the commit message apache#64: Regen # This is the commit message apache#65: Upgrade Chronicle Bytes to version 1.9.7 # This is the commit message apache#66: Upgrade Chronicle Core to version 1.9.4 # This is the commit message apache#67: Upgrade Chronicle Network to version 1.9.3 # This is the commit message apache#68: Upgrade Chronicle Wire to version 1.9.11 # This is the commit message apache#69: Upgrade RxJava to version 2.1.3 # This is the commit message apache#70: CAMEL-11694 - Camel-Hazelcast: Add more operation to queue - Take operation # This is the commit message apache#71: CAMEL-11694 - Camel-Hazelcast: Add more operation to queue - Retain All operation # This is the commit message apache#72: CAMEL-11694 - Camel-Hazelcast: Add more operation to queue - Docs updated # This is the commit message apache#73: CAMEL-11692: Set ClassLoader property on HBase configuration # This is the commit message apache#74: CAMEL-11666 - Camel Hazelcast Queue Consumer implementation # This is the commit message apache#75: CAMEL-11666 - Fixed CS and regen docs # This is the commit message apache#76: CAMEL-11666 - Improved docs # This is the commit message apache#77: CAMEL-11697 - S3 Consumer: If maxMessagesPerPoll is greater than 50 consumer fails to poll objects from bucket # This is the commit message apache#78: CAMEL-11697 - Updated docs # This is the commit message apache#79: CAMEL-9608 following up to take care of sharedEntityManager # This is the commit message apache#80: CAMEL-11697 - S3 Consumer: If maxMessagesPerPoll is greater than 50 consumer fails to poll objects from bucket - Set the maxConnections equals to default value + maxMessagesPoll # This is the commit message apache#81: CAMEL-8010:Locking the critical section to avoid race condition if AggregateTimeOutChecker also completes at the same time as Recover task # This is the commit message apache#82: CAMEL-8010:Included onSubmitCompletion in the lock section to prevent race condiditon # This is the commit message apache#83: CAMEL-8010:Included onSubmitCompletion in the lock section to prevent race condiditon # This is the commit message apache#84: CAMEL-8010:Reverted previous push since AggregatorLockingTest failed # This is the commit message apache#85: CAMEL-8010:Fixed checkstyle # This is the commit message apache#86: CAMEL-11645 - Add pattern exclusion mechanism similar to the one provided by the camel-zipkin component # This is the commit message apache#87: CAMEL-11701 - Camel-AWS S3: Use AmazonS3ClientBuilder instead of different constructors # This is the commit message apache#88: ComponentExtension : allow to unwrap to concrete extension. # This is the commit message apache#89: MetaDataExtension : allow to retrieve attributes directly # This is the commit message apache#90: CAMEL-11703 - Camel-AWS: Use builders instead of different constructors - AWS CloudWatch # This is the commit message apache#91: CAMEL-11703 - Camel-AWS: Use builders instead of different constructors - AWS DynamoDB # This is the commit message apache#92: CAMEL-11703 - Camel-AWS: Use builders instead of different constructors - AWS EC2 # This is the commit message apache#93: CAMEL-11703 - Camel-AWS: Use builders instead of different constructors - AWS SimpleDB # This is the commit message apache#94: CAMEL-11703 - Camel-AWS: Use builders instead of different constructors - AWS SimpleEmail # This is the commit message apache#95: CAMEL-11703 - Camel-AWS: Use builders instead of different constructors - AWS SNS # This is the commit message apache#96: CAMEL-11703 - Camel-AWS: Use builders instead of different constructors - AWS SQS # This is the commit message apache#97: CAMEL-11703 - Camel-AWS: Use builders instead of different constructors - AWS SWF # This is the commit message apache#98: Upgrade Weld3 to version 3.0.1.Final # This is the commit message apache#99: CAMEL-11705 - Camel-Caffeine: ExpireAfterAccess set two times instead of ExpireAfterWrite # This is the commit message apache#100: CAMEL-ASN1 - ASN.1 Data Format Component with Bouncy Castle-bcprov-jdk15on and openmuc-jasn1 # This is the commit message apache#101: CAMEL-11612-updated per code review # This is the commit message apache#102: CAMEL-11612-code review fixes # This is the commit message apache#103: CAMEL-11612 - rebase
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
This patch introduces HazelcastAggregationRepository class that implements RecoverableAggregationRepository and OptimisticLockingAggregationRepository. This class uses a Hazelcast distributed maps as a backing store for operational and persisted exchanges.
This repository is aimed to support aggregation in an environment where multiple hosts run identical Camel routes which participate an aggregation process.