@Test
public void testUpdateLTXWhenMessageExist() {

    // Setup
    final LocalTransactionStepDefinition pipeline = mock(LocalTransactionStepDefinition.class);
    final LocalTransaction ltx = mock(LocalTransaction.class);
    final BubbleMessage bubbleMessage = mock(BubbleMessage.class);
    final String fltx = "fltx";
    when(mockTxUtilities.getBubleMessage(pipeline)).thenReturn(Optional.of(bubbleMessage));
    when(bubbleMessage.getFLTX()).thenReturn(fltx);
    // Run the test
    businessLocalTransactionManagerImplUnderTest.updateLTX(pipeline, ltx);
    // Verify the results
    verify(ltx).setFLTX(fltx);
}