import com.lightbend.lagom.javadsl.persistence.PersistentEntityRef; //导入依赖的package包/类
public ServiceCall<NotUsed, String> hello(String id) {
  return request -> {
    // Look up the hello world entity for the given ID.
    PersistentEntityRef<HelloCommand> ref = persistentEntityRegistry.refFor(HelloEntity.class, id);
    // Ask the entity the Hello command.
    return ref.ask(new Hello(id, Optional.empty()));
  };
}
 

import com.lightbend.lagom.javadsl.persistence.PersistentEntityRef; //导入依赖的package包/类
public ServiceCall<GreetingMessage, Done> useGreeting(String id) {
  return request -> {
    // Look up the hello world entity for the given ID.
    PersistentEntityRef<HelloCommand> ref = persistentEntityRegistry.refFor(HelloEntity.class, id);
    // Tell the entity to use the greeting name specified.
    return ref.ask(new UseGreetingMessage(request.message));
  };

}
 

import com.lightbend.lagom.javadsl.persistence.PersistentEntityRef; //导入依赖的package包/类
@Override
public ServiceCall<String, Leg, Done> addLeg() {
    return (id, request) -> {
        CompletionStage<Cargo> response = registrationService.getRegistration().invoke(request.getCargoId(), NotUsed.getInstance());
        PersistentEntityRef<ShippingCommand> itinerary = persistentEntityRegistry.refFor(ItineraryEntity.class, id);
        return itinerary.ask(AddLeg.of(request));
    };
}
 

import com.lightbend.lagom.javadsl.persistence.PersistentEntityRef; //导入依赖的package包/类
@Override
public ServiceCall<NotUsed, Itinerary, Done> createItinerary() {
    return (id, request) -> {
        // Look up the itinerary for the given ID.
        PersistentEntityRef<ShippingCommand> itinerary =
            persistentEntityRegistry.refFor(ItineraryEntity.class, request.getId());
        // Tell the entity to use the greeting message specified.
        return itinerary.ask(CreateItinerary.of(request));
    };
}
 

import com.lightbend.lagom.javadsl.persistence.PersistentEntityRef; //导入依赖的package包/类
/**
 * Register Cargo service call
 *
 * @return
 */
@Override
public ServiceCall<NotUsed, Cargo, Done> register() {
    return (id, request) -> {
        /* Publish received entity into topic named "Topic" */
        PubSubRef<Cargo> topic = topics.refFor(TopicId.of(Cargo.class, "topic"));
        topic.publish(request);
        log.info("Cargo ID: {}.", request.getId());
        /* Look up the Cargo entity for the given ID. */
        PersistentEntityRef<RegistrationCommand> ref =
                persistentEntityRegistry.refFor(CargoEntity.class, request.getId());
        /* Tell the entity to use the Cargo information in the request. */
        return ref.ask(RegisterCargo.of(request));
    };
}
 

import com.lightbend.lagom.javadsl.persistence.PersistentEntityRef; //导入依赖的package包/类
@Override
public ServiceCall<NotUsed, String> hello(String id) {
    return request -> {
        // Look up the hello world entity for the given ID.
        PersistentEntityRef<HelloCommand> ref = persistentEntityRegistry.refFor(HelloEntity.class, id);
        // Ask the entity the Hello command.
        return ref.ask(new Hello(id, Optional.empty()));
    };
}
 

import com.lightbend.lagom.javadsl.persistence.PersistentEntityRef; //导入依赖的package包/类
@Override
public ServiceCall<GreetingMessage, Done> useGreeting(String id) {
    return request -> {
        // Look up the hello world entity for the given ID.
        PersistentEntityRef<HelloCommand> ref = persistentEntityRegistry.refFor(HelloEntity.class, id);
        // Tell the entity to use the greeting message specified.
        return ref.ask(new UseGreetingMessage(request.message));
    };

}
 

import com.lightbend.lagom.javadsl.persistence.PersistentEntityRef; //导入依赖的package包/类
private PersistentEntityRef<InventoryCommand> refFor(UUID id) {
    return registry
            .refFor(InventoryEntity.class, "main-warehouse-" + id.toString());
}
 

import com.lightbend.lagom.javadsl.persistence.PersistentEntityRef; //导入依赖的package包/类
private PersistentEntityRef<BasketCommand> refFor(UUID id) {
    return registry.refFor(BasketEntity.class, id.toString());
}
 

import com.lightbend.lagom.javadsl.persistence.PersistentEntityRef; //导入依赖的package包/类
private PersistentEntityRef<FriendCommand> friendEntityRef(String userId) {
  PersistentEntityRef<FriendCommand> ref = persistentEntities.refFor(FriendEntity.class, userId);
  return ref;
}
 

import com.lightbend.lagom.javadsl.persistence.PersistentEntityRef; //导入依赖的package包/类
private PersistentEntityRef<FavoriteCommand> favoriteEntityRef(String userId) {
    return this.persistentEntities.refFor(FavoriteEntity.class, userId);
}