@Test
void onTopicMessage() throws Exception {

    // given
    TopicMessage topicMessage = getTopicMessage();
    // when
    sqlEntityListener.onTopicMessage(topicMessage);
    completeFileAndCommit();
    // then
    assertEquals(1, topicMessageRepository.count());
    assertExistsAndEquals(topicMessageRepository, topicMessage, topicMessage.getConsensusTimestamp());
}