@Test
void onTokenAccount() throws Exception {

    String tokenId1 = "0.0.3";
    String tokenId2 = "0.0.5";
    String accountId1 = "0.0.7";
    String accountId2 = "0.0.11";
    TokenAccount tokenAccount1 = getTokenAccount(tokenId1, accountId1);
    TokenAccount tokenAccount2 = getTokenAccount(tokenId2, "0.0.11");
    // when
    sqlEntityListener.onTokenAccount(tokenAccount1);
    sqlEntityListener.onTokenAccount(tokenAccount2);
    completeFileAndCommit();
    // then
    assertEquals(2, tokenAccountRepository.count());
    assertExistsAndEquals(tokenAccountRepository, tokenAccount1, new TokenAccount.Id(EntityId
            .of(tokenId1, EntityTypeEnum.TOKEN), EntityId.of(accountId1, ACCOUNT)));
    assertExistsAndEquals(tokenAccountRepository, tokenAccount2, new TokenAccount.Id(EntityId
            .of(tokenId2, EntityTypeEnum.TOKEN), EntityId.of(accountId2, ACCOUNT)));
}