2323use Ecotone \Modelling \AggregateFlow \SaveAggregate \AggregateResolver \AggregateDefinitionRegistry ;
2424use Ecotone \Modelling \AggregateMessage ;
2525use Ecotone \Modelling \CommandBus ;
26- use Ecotone \Modelling \Config \AggregrateHandlerModule ;
26+ use Ecotone \Modelling \Config \AggregrateModule ;
2727use Ecotone \Modelling \Config \MessageBusChannel ;
2828use Ecotone \Modelling \Event ;
2929use Ecotone \Modelling \EventBus ;
@@ -194,7 +194,7 @@ public function withEventsFor(string|object|array $identifiers, string $aggregat
194194 AggregateMessage::CALLED_AGGREGATE_INSTANCE => new $ aggregateClass (),
195195 AggregateMessage::RECORDED_AGGREGATE_EVENTS => $ events ,
196196 ],
197- AggregrateHandlerModule ::getRegisterAggregateSaveRepositoryInputChannel ($ aggregateClass ). '.test_setup_state '
197+ AggregrateModule ::getRegisterAggregateSaveRepositoryInputChannel ($ aggregateClass ). '.test_setup_state '
198198 );
199199
200200 return $ this ;
@@ -208,7 +208,7 @@ public function withStateFor(object $aggregate): self
208208 AggregateMessage::CALLED_AGGREGATE_INSTANCE => $ aggregate ,
209209 AggregateMessage::CALLED_AGGREGATE_CLASS => $ aggregate ::class,
210210 ],
211- AggregrateHandlerModule ::getRegisterAggregateSaveRepositoryInputChannel ($ aggregate ::class). '.test_setup_state '
211+ AggregrateModule ::getRegisterAggregateSaveRepositoryInputChannel ($ aggregate ::class). '.test_setup_state '
212212 );
213213
214214 return $ this ;
@@ -347,7 +347,7 @@ public function getAggregate(string $className, string|int|array|object $identif
347347 [
348348 AggregateMessage::OVERRIDE_AGGREGATE_IDENTIFIER => is_object ($ identifiers ) ? (string )$ identifiers : $ identifiers ,
349349 ],
350- AggregrateHandlerModule ::getRegisterAggregateLoadRepositoryInputChannel ($ className , false )
350+ AggregrateModule ::getRegisterAggregateLoadRepositoryInputChannel ($ className , false )
351351 );
352352 }
353353
0 commit comments