sample.java

	/**
	 * 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()
				.thenApply(handleGetState);
	}

	/**
	 * @return Persistent entity actor reference based into AKKA cluster sharding
	 */
	private final ActorRef getOrderEntity() {
		return persistentEntityBroker.findPersistentEntity(OrderManager.class);

	}