Skip to content

Commit

Permalink
testing iosas integration
Browse files Browse the repository at this point in the history
  • Loading branch information
Harry0589 committed Apr 4, 2024
1 parent b49cc8a commit 86ce550
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,10 +18,16 @@ public enum SagaTopicsEnum {
* Pen replication authority create saga topic saga topics enum.
*/
PEN_REPLICATION_AUTHORITY_CREATE_SAGA_TOPIC("PEN_REPLICATION_AUTHORITY_CREATE_SAGA_TOPIC"),

PEN_REPLICATION_AUTHORITY_UPDATE_SAGA_TOPIC("PEN_REPLICATION_AUTHORITY_UPDATE_SAGA_TOPIC"),

/**
* Pen replication school create saga topic saga topics enum.
*/
PEN_REPLICATION_SCHOOL_CREATE_SAGA_TOPIC("PEN_REPLICATION_SCHOOL_CREATE_SAGA_TOPIC"),

PEN_REPLICATION_SCHOOL_UPDATE_SAGA_TOPIC("PEN_REPLICATION_SCHOOL_UPDATE_SAGA_TOPIC"),

/**
* Pen replication district create saga topic saga topics enum.
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ public class AuthorityUpdateOrchestrator extends BaseOrchestrator<AuthorityUpdat


protected AuthorityUpdateOrchestrator(final SagaService sagaService, final MessagePublisher messagePublisher, final EntityManagerFactory entityManagerFactory, final RestUtils restUtils, AuthorityCreateService authorityCreateService) {
super(entityManagerFactory, sagaService, messagePublisher, AuthorityUpdateSagaData.class, SagaEnum.PEN_REPLICATION_AUTHORITY_UPDATE_SAGA, SagaTopicsEnum.PEN_REPLICATION_AUTHORITY_CREATE_SAGA_TOPIC);
super(entityManagerFactory, sagaService, messagePublisher, AuthorityUpdateSagaData.class, SagaEnum.PEN_REPLICATION_AUTHORITY_UPDATE_SAGA, SagaTopicsEnum.PEN_REPLICATION_AUTHORITY_UPDATE_SAGA_TOPIC);
this.restUtils = restUtils;
this.authorityMasterRepository = authorityMasterRepository;
this.authorityMapperHelper = authorityMapperHelper;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ public class SchoolUpdateOrchestrator extends BaseOrchestrator<SchoolUpdateSagaD


protected SchoolUpdateOrchestrator(final SagaService sagaService, final MessagePublisher messagePublisher, final EntityManagerFactory entityManagerFactory, final RestUtils restUtils, SchoolCreateService schoolCreateService, SchoolMasterRepository schoolMasterRepository, final SchoolMapperHelper schoolMapperHelper) {
super(entityManagerFactory, sagaService, messagePublisher, SchoolUpdateSagaData.class, SagaEnum.PEN_REPLICATION_SCHOOL_CREATE_SAGA, SagaTopicsEnum.PEN_REPLICATION_SCHOOL_CREATE_SAGA_TOPIC);
super(entityManagerFactory, sagaService, messagePublisher, SchoolUpdateSagaData.class, SagaEnum.PEN_REPLICATION_SCHOOL_UPDATE_SAGA, SagaTopicsEnum.PEN_REPLICATION_SCHOOL_UPDATE_SAGA_TOPIC);
this.restUtils = restUtils;
this.schoolCreateService = schoolCreateService;
this.schoolMasterRepository = schoolMasterRepository;
Expand Down

0 comments on commit 86ce550

Please sign in to comment.