Toggle navigation
Home
org.axonframework.eventhandling.Segment to java.util.List<org.axonframework.eventhandling.Segment>
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'AxonFramework'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Add or Remove Method invocation
unitOfWork.executeWithResult(() -> { MessageMonitor.MonitorCallback monitorCallback=messageMonitor.onMessageIngested(unitOfWork.getMessage()); return new DefaultInterceptorChain<>(unitOfWork,interceptors,m -> { try { eventHandlerInvoker.handle(m,segment); monitorCallback.reportSuccess(); return null; } catch ( Exception exception) { monitorCallback.reportFailure(exception); throw exception; } } ).proceed(); } ,rollbackConfiguration)
to
unitOfWork.executeWithResult(() -> { MessageMonitor.MonitorCallback monitorCallback=messageMonitor.onMessageIngested(unitOfWork.getMessage()); return new DefaultInterceptorChain<>(unitOfWork,interceptors,m -> { try { for ( Segment processingSegment : processingSegments) { eventHandlerInvoker.handle(m,processingSegment); } monitorCallback.reportSuccess(); return null; } catch ( Exception exception) { monitorCallback.reportFailure(exception); throw exception; } } ).proceed(); } ,rollbackConfiguration)
Rename Variable
segment
to
processingSegments