I have some questions about the design. 1. It seems that omega should hold on after consuming the event message from Kafka instead of completing pushing message. 2. Also we should consider about recovery, it seems that recovery is as same as before based on database.
------------------ Zhao Jun Apache Sharding-Sphere & ServiceComb > On Jun 21, 2019, at 6:41 PM, Zhang Lei <[email protected]> wrote: > > Hi, > > I have created the alpha-fsm module on branch SCB-1321 and submitted the > design documentation, state machine prototype and test cases. > If there is any problem, please let me know. > > Thanks, > Lei Zhang > > [1] https://github.com/apache/servicecomb-pack/tree/SCB-1321/alpha/alpha-fsm > <https://github.com/apache/servicecomb-pack/tree/SCB-1321/alpha/alpha-fsm> > >> 在 2019年6月20日，下午3:25，Zheng Feng <[email protected]> 写道： >> >> Yeah, I think Willem has create one [1] before and do you mind I assign >> this issue to you ? >> >> [1] https://issues.apache.org/jira/browse/SCB-1258 >> >> Zhang Lei <[email protected]> 于2019年6月20日周四 下午2:34写道： >> >>> Hi, Zheng Feng >>> >>> Thanks for your advice, I will create a JIRA first and start with the >>> design documentation. >>> >>> Lei Zhang >>> >>>> 在 2019年6月19日，下午8:09，Zheng Feng <[email protected]> 写道： >>>> >>>> Thanks a lot for sharing these information ! I think this state machine >>>> could be very experimental so it would helpful to create an experimental >>>> branch to add this module but not in the master branch. >>>> >>>> Zhang Lei <[email protected]> 于2019年6月19日周三 下午5:42写道： >>>> >>>>> I have completed some of the design and prototype in my github. >>>>> >>>>> In the design document [1] my original idea was that a transaction >>>>> consisted of a SagaActor and several TxActors, and later TxAcotr was >>>>> removed to reduce implementation complexity. >>>>> I haven't had time to modify the documentation yet, but the SagaActor >>>>> state machine [2] is up to date. >>>>> Here you can see the test cases of SagaActor [3] >>>>> >>>>> [1] >>>>> >>> https://github.com/coolbeevip/playground/tree/master/state_machine_demo/saga-akkafsm >>>>> < >>>>> >>> https://github.com/coolbeevip/playground/tree/master/state_machine_demo/saga-akkafsm >>>>>> >>>>> [2] >>>>> >>> https://github.com/coolbeevip/playground/blob/master/state_machine_demo/saga-akkafsm/assets/saga_state_diagram.png >>>>> < >>>>> >>> https://github.com/coolbeevip/playground/blob/master/state_machine_demo/saga-akkafsm/assets/saga_state_diagram.png >>>>>> >>>>> [3] >>>>> >>> https://github.com/coolbeevip/playground/blob/master/state_machine_demo/saga-akkafsm/src/test/java/coolbeevip/playgroud/statemachine/saga/SagaActorTest.java >>>>> < >>>>> >>> https://github.com/coolbeevip/playground/blob/master/state_machine_demo/saga-akkafsm/src/test/java/coolbeevip/playgroud/statemachine/saga/SagaActorTest.java >>>>>> >>>>> >>>>> Lei Zhang >>>>> >>>>> >>>>>> 在 2019年6月19日，下午2:34，zhaojun <[email protected]> 写道： >>>>>> >>>>>> If we use AKKA, how can we design the actors, and how can we guarantee >>>>> omega will receive the message synchronize. >>>>> >>>>> >>> >>> >
