MCPcopy Create free account

hub / github.com/Haybu/demo-spring-distributed-transaction / functions

Functions87 in github.com/Haybu/demo-spring-distributed-transaction

⨍ Functions 87◇ Types & classes 40
↓ 24 callersMethodgetJobId
()
commons/src/main/java/io/agilehandy/commons/api/database/DBRequest.java:23
↓ 23 callersMethodgetGlobalTxnId
()
commons/src/main/java/io/agilehandy/commons/api/database/DBRequest.java:22
↓ 14 callersMethodsignalStateMachine
(Long jobId, String txnId , JobExchange request, JobEvent signal)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:170
↓ 6 callersMethodsimulateTxn
(int max, int lowerBound, int higherBound , int maxSecondsToDelay)
remote-services/src/main/java/io/agilehandy/remote/handlers/Utilities.java:25
↓ 5 callersMethodgetFileId
()
commons/src/main/java/io/agilehandy/commons/api/storage/FileRequest.java:24
↓ 5 callersMethodgetRecordId
()
commons/src/main/java/io/agilehandy/commons/api/database/DBRequest.java:24
↓ 4 callersMethodcreateBCResponse
(BCRequest request, JobEvent result)
remote-services/src/main/java/io/agilehandy/remote/handlers/BCHandler.java:97
↓ 4 callersMethodcreateDBResponse
(DBRequest request, JobEvent result)
remote-services/src/main/java/io/agilehandy/remote/handlers/DBHandler.java:97
↓ 4 callersMethodcreateFileResponse
(FileRequest request, JobEvent result)
remote-services/src/main/java/io/agilehandy/remote/handlers/FileHandler.java:97
↓ 4 callersMethodgetFilename
()
commons/src/main/java/io/agilehandy/commons/api/storage/FileRequest.java:25
↓ 3 callersMethodaction
(StateMachine<JobState, JobEvent> sm , Function<StateContext<JobState, JobEvent>, Mono<Void>> action , l
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachineMonitor.java:57
↓ 3 callersMethodaddTransactionRequest
(FileSubmitRequest request)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:192
↓ 3 callersMethodgetContentId
()
commons/src/main/java/io/agilehandy/commons/api/blockchain/BCRequest.java:24
↓ 3 callersMethodtxnResponseOut
()
remote-services/src/main/java/io/agilehandy/remote/handlers/EventChannels.java:45
↓ 2 callersMethodbcRequestOut
()
saga/src/main/java/io/agilehandy/txn/saga/SagaChannels.java:42
↓ 2 callersMethoddbRequestOut
()
saga/src/main/java/io/agilehandy/txn/saga/SagaChannels.java:39
↓ 2 callersMethodfileRequestOut
()
saga/src/main/java/io/agilehandy/txn/saga/SagaChannels.java:36
↓ 2 callersMethodhandleBcCancelAction
(StateContext<JobState, JobEvent> stateContext)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachine.java:287
↓ 2 callersMethodhandleDbCancelAction
(StateContext<JobState, JobEvent> stateContext)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachine.java:263
↓ 2 callersMethodhandleFileCancelAction
(StateContext<JobState, JobEvent> stateContext)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachine.java:239
↓ 2 callersMethodsendResponse
(BCTxnResponse response)
remote-services/src/main/java/io/agilehandy/remote/handlers/BCHandler.java:90
↓ 2 callersMethodsendResponse
(FileTxnResponse response)
remote-services/src/main/java/io/agilehandy/remote/handlers/FileHandler.java:90
↓ 2 callersMethodsendResponse
(DBTxnResponse response)
remote-services/src/main/java/io/agilehandy/remote/handlers/DBHandler.java:90
↓ 1 callersMethodcanOrchestrate
(Long jobId)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:116
↓ 1 callersMethodcreateJob
(Long jobId, String txnId, FileSubmitRequest fs, DBSubmitRequest db, BCSubmitRequest bc)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:152
↓ 1 callersMethoddelay
(int maxSecondsToDelay)
remote-services/src/main/java/io/agilehandy/remote/handlers/Utilities.java:37
↓ 1 callersMethodfindInProgressInstances
(Long jobId)
saga/src/main/java/io/agilehandy/txn/saga/job/JobRepository.java:25
↓ 1 callersMethodgetStateMachine
(String txnId, boolean isFirstEvent)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachineBuilder.java:28
↓ 1 callersMethodhandleBcSubmitAction
(StateContext<JobState, JobEvent> stateContext)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachine.java:275
↓ 1 callersMethodhandleDbSubmitAction
(StateContext<JobState, JobEvent> stateContext)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachine.java:251
↓ 1 callersMethodhandleFileSubmitAction
(StateContext<JobState, JobEvent> stateContext)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachine.java:227
↓ 1 callersMethodisTerminalState
()
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:146
↓ 1 callersMethodorchestrate
(Long jobId, FileSubmitRequest fsr , DBSubmitRequest dbr, BCSubmitRequest bcr)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:83
↓ 1 callersMethodstart
(Long jobId, String txnId)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:122
MethodBCHandler
(EventChannels eventChannels)
remote-services/src/main/java/io/agilehandy/remote/handlers/BCHandler.java:62
MethodDBHandler
(EventChannels eventChannels)
remote-services/src/main/java/io/agilehandy/remote/handlers/DBHandler.java:62
MethodFileHandler
(EventChannels eventChannels)
remote-services/src/main/java/io/agilehandy/remote/handlers/FileHandler.java:62
MethodJobKey
()
saga/src/main/java/io/agilehandy/txn/saga/job/JobKey.java:28
MethodSaga
()
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:73
MethodSagaStateMachine
(SagaChannels channels, SagaStateMachineMonitor monitor, StateMachineRuntimePersister<JobState, JobEvent, Stri
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachine.java:57
MethodSagaStateMachineInterceptor
(StateMachineService<JobState, JobEvent> stateMachineService , JobRepository jobRepository)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachineInterceptor.java:41
MethodSagaStateMachineJpaBuilder
(StateMachineService<JobState, JobEvent> stateMachineService , JobRepository jobRepository)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachineJpaBuilder.java:37
MethodWebController
(Saga saga)
saga/src/main/java/io/agilehandy/txn/saga/web/WebController.java:34
MethodbcRequestIn
()
remote-services/src/main/java/io/agilehandy/remote/handlers/EventChannels.java:42
Methodconfigure
(StateMachineConfigurationConfigurer<JobState, JobEvent> config)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachine.java:63
MethodcontextLoads
()
saga/src/test/java/io/agilehandy/txn/SagaApplicationTests.java:10
MethodcontextLoads
()
remote-services/src/test/java/io/agilehandy/remote/RemoteServicesApplicationTests.java:10
MethodcontextLoads
()
commons/src/test/java/io/agilehandy/commons/CommonsApplicationTests.java:10
MethoddbRequestIn
()
remote-services/src/main/java/io/agilehandy/remote/handlers/EventChannels.java:39
MethodfileRequestIn
()
remote-services/src/main/java/io/agilehandy/remote/handlers/EventChannels.java:36
MethodfindJobsByJobId
(Long jobId)
saga/src/main/java/io/agilehandy/txn/saga/job/JobRepository.java:29
MethodgetGlobalTxnId
()
commons/src/main/java/io/agilehandy/commons/api/storage/FileRequest.java:22
MethodgetGlobalTxnId
()
commons/src/main/java/io/agilehandy/commons/api/blockchain/BCRequest.java:22
MethodgetJobId
()
commons/src/main/java/io/agilehandy/commons/api/storage/FileRequest.java:23
MethodgetJobId
()
commons/src/main/java/io/agilehandy/commons/api/blockchain/BCRequest.java:23
MethodgetStateMachine
(String txnId, boolean isFirstEvent)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachineJpaBuilder.java:43
MethodhandleBCCancelComplete
(@Payload BCTxnResponse response)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:338
MethodhandleBCCancelFail
(@Payload BCTxnResponse response)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:352
MethodhandleBCSubmitComplete
(@Payload BCTxnResponse response)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:315
MethodhandleBCSubmitFail
(@Payload BCTxnResponse response)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:325
MethodhandleCancelBC
(@Payload BCCancelRequest request)
remote-services/src/main/java/io/agilehandy/remote/handlers/BCHandler.java:78
MethodhandleCancelDB
(@Payload DBCancelRequest request)
remote-services/src/main/java/io/agilehandy/remote/handlers/DBHandler.java:78
MethodhandleCancelFile
(@Payload FileCancelRequest request)
remote-services/src/main/java/io/agilehandy/remote/handlers/FileHandler.java:78
MethodhandleDBCancelComplete
(@Payload DBTxnResponse response)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:285
MethodhandleDBCancelFail
(@Payload DBTxnResponse response)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:301
MethodhandleDBSubmitComplete
(@Payload DBTxnResponse response)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:261
MethodhandleDBSubmitFail
(@Payload DBTxnResponse response)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:271
MethodhandleFileCancelComplete
(@Payload FileTxnResponse response)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:237
MethodhandleFileCancelFail
(@Payload FileTxnResponse response)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:247
MethodhandleFileSubmitComplete
---------------------------------------- stream listeners ----------------------------------------
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:213
MethodhandleFileSubmitFail
(@Payload FileTxnResponse response)
saga/src/main/java/io/agilehandy/txn/saga/Saga.java:222
MethodhandleSubmitBC
(@Payload BCSubmitRequest request)
remote-services/src/main/java/io/agilehandy/remote/handlers/BCHandler.java:66
MethodhandleSubmitDB
(@Payload DBSubmitRequest request)
remote-services/src/main/java/io/agilehandy/remote/handlers/DBHandler.java:66
MethodhandleSubmitFile
(@Payload FileSubmitRequest request)
remote-services/src/main/java/io/agilehandy/remote/handlers/FileHandler.java:66
Methodmain
(String[] args)
saga/src/main/java/io/agilehandy/txn/SagaApplication.java:13
Methodmain
(String[] args)
remote-services/src/main/java/io/agilehandy/remote/RemoteServicesApplication.java:9
Methodmain
(String[] args)
commons/src/main/java/io/agilehandy/commons/CommonsApplication.java:9
MethodpostStateChange
(State<JobState, JobEvent> state, Message<JobEvent> message, Transition<JobState, JobEvent> transition, StateM
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachineInterceptor.java:61
MethodpreStateChange
(State<JobState, JobEvent> state, Message<JobEvent> message, Transition<JobState, JobEvent> transition, StateM
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachineInterceptor.java:47
MethodrunTransaction
(@RequestBody TxnRequest request)
saga/src/main/java/io/agilehandy/txn/saga/web/WebController.java:38
MethodstateExited
(State state)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachine.java:71
MethodstateMachineRuntimePersister
( JpaStateMachineRepository jpaStateMachineRepository)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaMachinePersistJpaConfig.java:36
MethodstateMachineService
( StateMachineFactory<JobState, JobEvent> stateMachineFactory, StateMachineRuntimePersister<JobState, Jo
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaMachinePersistJpaConfig.java:42
MethodstateMachineStarted
(StateMachine stateMachine)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachine.java:66
MethodstateMachineStopped
(StateMachine stateMachine)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachine.java:76
Methodtransition
(StateMachine<JobState, JobEvent> sm , Transition<JobState, JobEvent> trans , long duration)
saga/src/main/java/io/agilehandy/txn/saga/machine/SagaStateMachineMonitor.java:39
MethodtxnResponseIn
()
saga/src/main/java/io/agilehandy/txn/saga/SagaChannels.java:45