Fix: enforce a timeout to detect TCP connections which have failed silently (no error from the socket). If the client does not receive any regular activity or heartbeat on a connection for one minute, the connection is shut down and recreated.
Fix: sending uses an internal pipe to signal Proton-J, and the pipe could sometimes fill up with redundant signals, causing a stall. Do not signal if Proton-J is already handling sends.
Addition: method PartitionReceiver.getIsOpen() added to help the Spark connector.
There are no changes to Event Processor Host except updating the dependency to the new client.
This release was made from the Azure SDK for Java repository. This repository is deprecated and the code here is for historical purposes only. See these tags for the code base for this release:
https://github.com/Azure/azure-sdk-for-java/releases/tag/azure-eventhubs_3.0.2
https://github.com/Azure/azure-sdk-for-java/releases/tag/azure-eventhubs-eph_3.0.2
https://github.com/Azure/azure-sdk-for-java/releases/tag/azure-eventhubs-extensions_3.0.2
Maven packages:
https://mvnrepository.com/artifact/com.microsoft.azure/azure-eventhubs/3.0.2
https://mvnrepository.com/artifact/com.microsoft.azure/azure-eventhubs-eph/3.0.2
https://mvnrepository.com/artifact/com.microsoft.azure/azure-eventhubs-extensions/3.0.2