mindol1004/reactive-stock-market
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update CommandBus.java

Browse Source 
update doc
This commit is contained in:
Stefan
2022-05-30 23:21:26 +02:00
committed by GitHub
parent 8002bdcaa4
commit 378fb7cffa
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/io/bux/matchingengine/domain/bus/CommandBus.java
View File

@@ -20,7 +20,7 @@ import javax.annotation.PreDestroy;
* <p> * <p>
* Routes command for district assets/aggregates in parallel, but routes commands withing one aggregate sequentially. * Routes command for district assets/aggregates in parallel, but routes commands withing one aggregate sequentially.
* <p> * <p>
* Locking is done by Reactor {@see <a href="https://github.com/reactor/reactor-core/blob/178e0c7cf799122afdd6bf89be32975d2b433609/reactor-core/src/main/java/reactor/core/publisher/SinksSpecs.java#L46">tryAcquire</a>} * Thread synchronization is done by Reactor {@see <a href="https://github.com/reactor/reactor-core/blob/178e0c7cf799122afdd6bf89be32975d2b433609/reactor-core/src/main/java/reactor/core/publisher/SinksSpecs.java#L46">tryAcquire</a>}
* <p> * <p>
* Is fire and forget, canceling subscription will not change execution flow, but subscriber has option to "stay" and * Is fire and forget, canceling subscription will not change execution flow, but subscriber has option to "stay" and
* get signaled once corresponding event has been materialized or if execution has failed. * get signaled once corresponding event has been materialized or if execution has failed.