Skip to content

Instantly share code, notes, and snippets.

Created Apr 26, 2018
What would you like to do?
* get order state service API
* @param getOrderStatusCmd get Order state command
* @return order state
public CompletableFuture<OrderState> getOrderStatus(OrderCmd.GetOrderStatusCmd getOrderStatusCmd) {
return PatternsCS.ask(getOrderEntity(), getOrderStatusCmd, timeout).toCompletableFuture()
* @return Persistent entity actor reference based into AKKA cluster sharding
private final ActorRef getOrderEntity() {
return persistentEntityBroker.findPersistentEntity(OrderManager.class);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment