Skip to content

Commit 7e195aa

Browse files
vanroguclaude
andauthored
Refactor event processing to use Projector from eventstore library (#29)
* Replace EventuallyConsistentEventProcessor with Projector-based ProjectorProcessor Delegate all projection mechanics (bookmarks, batching, BatchAwareProjection callbacks) to the Projector from the eventstore library. The new ProjectorProcessor is a thin lifecycle wrapper providing background thread management, leader election modes, and start/stop/terminate control. - Add ProjectorProcessor wrapping Projector with Processor interface - Update ReadModelModule, OutboundModule, InboundModule to use ProjectorProcessor - ReadModelAdapter: simplify to implement BatchAwareProjection only (inherits Projection) - DispatcherAdapter, TranslatorAdapter: implement Projection (add eventQuery()) - Delete EventuallyConsistentEventProcessor (replaced by ProjectorProcessor) - Retain ThrowableAndEventReference and ExceptionWhileHandlingEventWithReference https://claude.ai/code/session_01QZvR1DxHBahjCzmcLQcoZG * Use EventReference.happenedAfter() instead of raw position comparison Position alone is not sufficient to determine event ordering. Use the semantic happenedAfter() method consistent with the rest of the codebase (e.g. DCBCommandContextImpl). https://claude.ai/code/session_01QZvR1DxHBahjCzmcLQcoZG * Remove orphaned exception classes no longer used after Projector migration ThrowableAndEventReference and ExceptionWhileHandlingEventWithReference were only used by EventuallyConsistentEventProcessor for manual exception unwrapping. ProjectorProcessor delegates error handling to the eventstore Projector, which surfaces errors via ProjectorException directly. https://claude.ai/code/session_01QZvR1DxHBahjCzmcLQcoZG --------- Co-authored-by: Claude <noreply@anthropic.com>
1 parent c9d5738 commit 7e195aa

File tree

8 files changed

+271
-414
lines changed

8 files changed

+271
-414
lines changed

sliceworkz-eventmodeling-impl/src/main/java/org/sliceworkz/eventmodeling/module/eventdispatching/EventuallyConsistentEventProcessor.java

Lines changed: 0 additions & 280 deletions
This file was deleted.

sliceworkz-eventmodeling-impl/src/main/java/org/sliceworkz/eventmodeling/module/eventdispatching/ExceptionWhileHandlingEventWithReference.java

Lines changed: 0 additions & 39 deletions
This file was deleted.

0 commit comments

Comments
 (0)