{"head":"415aa121634bd0cf9eb1462fbf72ee958e63cd8b","size":19,"push_id":45226507,"shas":[["7e079149a6b9ca31e8eb282503e231a911dfea33","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2134 Fixed CorrelationMessageHandler\nRemoved call to isComplete() since canRelease() returning 'true' already identifies a completed aggregate. Added validation to the cleanUpForReleasedGroup() method to make sure that the sequenceSize is only checked if the default SequenceSizeReleaseStrategy is used","Oleg Zhurakousky"],["78c2c91998679b82300b08f0e6ca58d9ffb8b962","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2134 Working on CorrelatingMessageHandler\nAdded supported uses cases tests, added logic to remember closed-out groups to CorrelatingMessageHandler","Oleg Zhurakousky"],["7691dcccebb37f8fcd1a3f042b017bebb04bdca5","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2134 added more tests to AggregatorSupportedUseCasesTests","Oleg Zhurakousky"],["4f2f6f9df368c496ecbd56fc5cfe18ae58a82835","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2134 added ResequensingMessageHandler","Oleg Zhurakousky"],["9bfef25ad25fc0e7f5591bda86f51acdd6ccc676","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2134\nAdded support for 'complete' attribute to SimpleMessageGroup, added logic to clean up MessageGroups that needs to be remembered from messages upon their completion","Oleg Zhurakousky"],["9487ef74a531e011438819ea60f6bd0b892cf76b","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2134\nAdded complete() method to MessageGroup interface, temporarily fixed KeyValueMessageGroup by adding complete() as a no-op method, removed casting to SimpleMessageGroup in CMH, made CMH abstract and changed its name to AbstractCorrelatingMessageHandler with abstract cleanUpForReleasedGroup(..) method, added AggregatingMessageHandler as a subclass of AbstractCorrelatingMessageHandler, fixed and polished affected test cases","Oleg Zhurakousky"],["d503d9edacf176f596921ad3ff62d28e8f26189a","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2134 fixed the spelling error in the class name","Oleg Zhurakousky"],["58b40ccc7a7e7a1c58a8d55d648f41978030d767","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2134 addressed the latest PR comments\nmade 'expireGroupsUponCompletion' attribute protected and moved its setter to the AggregatingMessageHandler, added '!this.shouldExpireGroupsUponCompletion()' check to the ResequencingMessageHandler.cleanUpForReleasedGroup(..) method, added IF (expireGroupsUponCompletion) to setExpireGroupsUponCompletion(..)","Oleg Zhurakousky"],["aba95d8e08bef309ab15c7baee361c54088baa3f","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2134 fixed comment in the test to reflect new attribute","Oleg Zhurakousky"],["1420b44adeb23eb4567ec58e2f6e114db2bd9e32","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2134 updated javadocs to reflect changes\nto the fact that CorrelatingMessageHandler had become AbstractCorrelatingMessageHandler","Oleg Zhurakousky"],["8aa920b6088bf59833482834cdf4e8fe09ee3c3f","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","addressing PR comments\nremoved comments from the tests, moved iterator() method to the MessageGroup, got rid of unsafe cast","Oleg Zhurakousky"],["a93bc9875f317fa040b117a90644a2ceb715c9a6","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2134 fixed javadoc comment","Oleg Zhurakousky"],["617ea23cf9842a2ee627b0654198473308e085b7","ed0f22cf63b84cf2abdd3b78a7a000430012ced9@vmware.com","removed the shouldExpire flag from ResequencingMessageHandler","Mark Fisher"],["ba64f1852090b24fa1538d155bce584b0fc7fac6","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2142 fixed merge conflicts with INT-2152\n\nINT-2142 polished GemfireMessageStore\npolished GemfireMessageStore code with assertions, added GemfireGroupStoreTests\n\nINT-2142 polished GemfireMessageStore\naddressed most of the comments in PR (e.g., removed synchronized blocks, removed 'cache' as instance variable etc.)\n\nINT-2142 final polishing of GemfireMessageStore\n\nINT-2142 added support for storing individual messages\nwhich are part of the MessageGroup","Oleg Zhurakousky"],["b993f54c15d606e0c6ab0f7d3c0746cf27b410af","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2158 added 'expire-groups-upon-completion' attribute to the Aggregator","Oleg Zhurakousky"],["0a8219b0a03703b032cbbc33ee6c1216bec9f798","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2155 added initial support for persisting state of MG\nadded MessageGroupWrapper, added support for persisting MessageGroupWrapper to Gemfire which allows for full restore of the MessageGroup state\n\nINT-2155 added support for storing MG state for Redis\n\nINT-2155 added Mongo support for persisting MG state\n\nINT-2155 adding missing MessageGroupWrapper\n\nINT-2155 working on JDBC module\nupdated CREATE schemas with new column ('complete'), made initial changes to JdbcMessageStore to reflect schema changes\n\nINT-2155 added completeGroup(..) method on the MessageGroupStore\nadded JDBC implementation of that method and tests\n\nINT-2155 added completeGroup(..) implementations to\nRedis, Mongo, Gemfire, SimpleMessageStore, updated schema.sql.vpp to regenerate schamas","Oleg Zhurakousky"],["2a50675be4fbd7290c397e996e6040e6aff81ef6","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2135 initial work\n\nINT-2135 added support for marking messages optionally\n\nINT-2135 added missing tests, moved 'mark-messages' to 2.1 schema\n\nINT-2135 polishing\n\nINT-2135 polished test\n\nINT-2135 polishing basedon PR comments\n\nINT-2135 polsihing added copoyright to the test\n\nINT-2135 removed 'release-strategy*' attributes from the Resequencer\n\nINT-2135 addressed PR comments\nchanged mark-messages to keep-released-messages, added sequence verification assertions to the Resequencer test\n\nINT-2135 Restructuring of MessageGroup and MessageGroupStore\nadded getLastReleasedMessageSequence()method on MessageGroup, added setLastReleasedSequenceNumberForGroup() to MessageGroupStore, polished related classes\n\nINT-2135 added missing method to other implementations of MessageStore","Oleg Zhurakousky"],["d4c208e3e847e90b24d6a7fcc209e2661e5c782a","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2135 added 'lastReleasedSequenceNumber' to all implementations of MessageGroupStore\n\nINT-2135 polished RedisMessageStore\n\nINT-2135 added AbstractKeyValueMessageStore\nSubclassed GemfireMessageStore and RedisMessageStore from it.\n\nINT-2135 polished MongoDbMessageStore\nrefactored MessageWrapper not to have multi-argument constructor\n\nINT-2135 more polishing of AbstractKeyValueMessageStore and its implementations\n\nINT-2135 polishing, addressed latest PR comments\n\nINT-2135 polishing, javadocs and few code comments\n\nINT-2135 plishing\nmade holder maps more precise Map<Object, MessageGroupMetadata> for MessageGroup and Map<UUID, Message<?>> for Message in AbstractKeyValueMessageStore thus removing the need for toString() calls\n\nINT-2135 addressed the latest round of PR comoments\n\nINT-2135 added type-safty check for Collection<Message<?>>\n\nINT-2135 addressed the latest round of PR comments","Oleg Zhurakousky"],["415aa121634bd0cf9eb1462fbf72ee958e63cd8b","b54a6429e29703a20d7b9c4a94fc2bfbc97e9816@vmware.com","INT-2135 refactored Redis implementation of MessageStore\n\nINT-2135 refactored GemfireMessageStore\n\nINT-2135 polishing\n\nINT-2135 polishing, added javadocs, assertions\n\nINT-2135 addressed the PR comments\nchanged iterator() implementation to be a bit lighter, removed exception messages from the Assert.isInstance, renamed doList() to doListKeys()\n\nINT-2135 polishing\n\nINT-2135 polishing, added more tests\n\nINT-2135 polishing","Oleg Zhurakousky"]],"ref":"refs/heads/INT-2152"}