import com.lightbend.lagom.javadsl.persistence.PersistentEntity; //导入依赖的package包/类
private Behavior closedBasket(BasketState state) {
    PersistentEntity<BasketCommand, PEBasketEvent, BasketState>.BehaviorBuilder b =
            this.newBehaviorBuilder(state);

    // TODO treat all commands gently instead of ignoring all which causes exceptions.
    return b.build();
}
 

import com.lightbend.lagom.javadsl.persistence.PersistentEntity; //导入依赖的package包/类
@Test
public void testRejectDuplicateCreate() {
  PersistentEntityTestDriver<FriendCommand, FriendEvent, FriendState> driver = new PersistentEntityTestDriver<>(
      system, new FriendEntity(), "user-1");
  driver.run(new CreateUser(new User("alice", "Alice")));

  Outcome<FriendEvent, FriendState> outcome = driver.run(
      new CreateUser(new User("alice", "Alice")));
  assertEquals(PersistentEntity.InvalidCommandException.class, outcome.getReplies().get(0).getClass());
  assertEquals(Collections.emptyList(), outcome.events());
  assertEquals(Collections.emptyList(), driver.getAllIssues());
}
 

import com.lightbend.lagom.javadsl.persistence.PersistentEntity; //导入依赖的package包/类
@Test
public void testRejectDuplicateCreate() {
  PersistentEntityTestDriver<FriendCommand, FriendEvent, FriendState> driver = new PersistentEntityTestDriver<>(
      system, new FriendEntity(), "user-1");
  driver.run(CreateUser.of(User.of("alice", "Alice")));

  Outcome<FriendEvent, FriendState> outcome = driver.run(
      CreateUser.of(User.of("alice", "Alice")));
  assertEquals(PersistentEntity.InvalidCommandException.class, outcome.getReplies().get(0).getClass());
  assertEquals(Collections.emptyList(), outcome.events());
  assertEquals(Collections.emptyList(), driver.getAllIssues());
}