[BUG] EventPositionIntegrationTest.receiveLatestMessages is flaky

[lmolkova]

The test checks if events were received from latest position.
For this it starts receiving events and then sends a batch, expecting to receive all of them.

What happens is that none is received. Based on logs the assumption is that receive link opens after events are sent

2023-03-07T16:56:01.9681873Z 2023-03-07 16:56:01.874 [main] [INFO] com.azure.messaging.eventhubs.EventPositionIntegrationTest - {"az.sdk.message":"sent events"}
2023-03-07T16:56:01.9684000Z 2023-03-07 16:56:01.882 [reactor-executor-91] [INFO] com.azure.messaging.eventhubs.implementation.AmqpReceiveLinkProcessor - {"az.sdk.message":"Link is active.","subscriberId":"rlp_c0302c_1678208161807","linkName":"0_89ecdf_1678208161807","credits":0}
2023-03-07T16:56:01.9688121Z 2023-03-07 16:56:01.882 [reactor-executor-91] [INFO] com.azure.core.amqp.implementation.handler.ReceiveLinkHandler - {"az.sdk.message":"onLinkRemoteOpen","connectionId":"MF_01b8c5_1678208161806","entityPath":"***/ConsumerGroups/$Default/Partitions/0","linkName":"0_89ecdf_1678208161807","remoteSource":"Source{address='***/ConsumerGroups/$Default/Partitions/0', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter={apache.org:selector-filter:string=org.apache.qpid.proton.codec.DecoderImpl$UnknownDescribedType@792ed6b7}, defaultOutcome=null, outcomes=null, capabilities=null}"}

receive_latest.log

Reproduces every once in a while in CI, but could not repro locally

[lmolkova]

fixed in #38738