AbstractCorrelatingMessageHandler

Source file "org/springframework/integration/aggregator/AbstractCorrelatingMessageHandler.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,556 of 1,5560%170 of 1700%1761763943949191
forceComplete(MessageGroup)1440%260%1414424211
onInit()930%200%1111232311
processMessageForGroup(Message, Object, UUID, Lock)890%120%77232311
completeGroup(Message, Object, MessageGroup, Lock)770%160%99242411
AbstractCorrelatingMessageHandler(MessageGroupProcessor, MessageGroupStore, CorrelationStrategy, ReleaseStrategy)760%60%44232311
scheduleGroupToForceComplete(MessageGroup)700%80%55191911
handleMessageInternal(Message)660%60%44151511
expireGroup(Object, MessageGroup, Lock)640%80%55141411
lambda$removeEmptyGroupAfterTimeout$7(UUID, long)590%60%44171711
start()410%100%66121211
getDiscardChannel()390%80%55121211
createGroupTimeoutProcessor()340%40%336611
obtainGroupTimeout(MessageGroup)310%60%449911
removeEmptyGroupAfterTimeout(UUID, long)260%n/a117711
stop()230%60%447711
setGroupConditionIfAny(Message, MessageGroup)210%20%225511
processForceRelease(Object, long, long)210%40%334411
cancelScheduledFutureIfAny(Object, UUID, boolean)200%40%336611
lambda$expireGroup$17(Object)200%20%222211
setLockRegistry(LockRegistry)180%20%225511
purgeOrphanedGroups()170%20%223311
lambda$scheduleGroupToForceComplete$10(Object, long, long)170%n/a116611
setReleaseStrategy(ReleaseStrategy)150%n/a115511
completeGroup(Object, MessageGroup, Lock)150%20%225511
setReleasePartialSequences(boolean)140%40%334411
compareSequences(Message, Message)140%n/a113311
lambda$expireGroup$16(Object)140%n/a112211
lambda$onInit$1()140%n/a111111
setExpireTimeout(long)130%20%223311
lambda$handleMessageInternal$2(Object, Message)130%n/a111111
discardMessage(Message)110%20%224411
lambda$completeGroup$18(Object)110%n/a111111
lambda$expireGroup$15(Object)110%n/a111111
lambda$forceComplete$14(Object)110%n/a111111
lambda$forceComplete$13(Object)110%n/a111111
lambda$scheduleGroupToForceComplete$11(MessageGroup)110%n/a111111
lambda$scheduleGroupToForceComplete$9(Object)110%n/a111111
lambda$removeEmptyGroupAfterTimeout$8(UUID)110%n/a111111
lambda$removeEmptyGroupAfterTimeout$6(UUID)110%n/a111111
lambda$cancelScheduledFutureIfAny$4(Object)110%n/a111111
lambda$processMessageForGroup$3(MessageGroup)110%n/a111111
AbstractCorrelatingMessageHandler(MessageGroupProcessor)100%n/a112211
setMessageStore(MessageGroupStore)100%n/a114411
scheduleGroupToForceComplete(Object)90%n/a113311
discardMessage(Message, Lock)90%20%224411
findLastReleasedSequenceNumber(Object, Collection)90%n/a112211
verifyResultCollectionConsistsOfMessages(Collection)90%n/a113311
lambda$verifyResultCollectionConsistsOfMessages$19(Class)90%n/a111111
lambda$forceComplete$12(Object)90%n/a111111
lambda$removeEmptyGroupAfterTimeout$5(UUID)90%n/a111111
remove(MessageGroup)80%n/a113311
AbstractCorrelatingMessageHandler(MessageGroupProcessor, MessageGroupStore)70%n/a112211
setCorrelationStrategy(CorrelationStrategy)70%n/a113311
setForceReleaseAdviceChain(List)70%n/a113311
setOutputProcessor(MessageGroupProcessor)70%n/a113311
setDiscardChannel(MessageChannel)70%n/a113311
setDiscardChannelName(String)70%n/a113311
store(Object, Message)60%n/a111111
destroy()60%n/a112211
lambda$setMessageStore$0(MessageGroupStore, MessageGroup)60%n/a111111
setExpireDurationMillis(long)50%n/a112211
afterRelease(MessageGroup, Collection, boolean)50%n/a112211
lambda$destroy$20(ScheduledFuture)50%n/a111111
setGroupTimeoutExpression(Expression)40%n/a112211
setSendPartialResultOnExpiry(boolean)40%n/a112211
setMinimumTimeoutForEmptyGroups(long)40%n/a112211
setExpireGroupsUponTimeout(boolean)40%n/a112211
setPopSequence(boolean)40%n/a112211
setReleaseLockBeforeSend(boolean)40%n/a112211
setExpireDuration(Duration)40%n/a112211
setGroupConditionSupplier(BiFunction)40%n/a112211
setApplicationEventPublisher(ApplicationEventPublisher)40%n/a112211
getOutputProcessor()30%n/a111111
isReleaseLockBeforeSend()30%n/a111111
getMessageStore()30%n/a111111
getExpireGroupScheduledFutures()30%n/a111111
getCorrelationStrategy()30%n/a111111
getReleaseStrategy()30%n/a111111
getGroupConditionSupplier()30%n/a111111
getDiscardChannelName()30%n/a111111
isSendPartialResultOnExpiry()30%n/a111111
isSequenceAware()30%n/a111111
getLockRegistry()30%n/a111111
isLockRegistrySet()30%n/a111111
getMinimumTimeoutForEmptyGroups()30%n/a111111
isReleasePartialSequences()30%n/a111111
getGroupTimeoutExpression()30%n/a111111
getEvaluationContext()30%n/a111111
isRunning()30%n/a111111
getComponentType()20%n/a111111
isExpireGroupsUponCompletion()20%n/a111111