Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merging dev branch changes to master for 1.0.1 release. (#148)
* Bumping up client version to 1.0.1 (#107) * Fixing build break introduced with preview check-in. * Bumping up the client version to 1.0.1 * Adding 2 new epoch unit tests (#108) * Fixing build break introduced with preview check-in. * Adding 2 new epoch receiver unit tests. * Update readme.md (#110) Fixed broken links. * Deliver receiver disconnected exception to client (#109) * Fixing build break introduced with preview check-in. * + PartitionPump to deliver ReceiverDisconnectedException to processor host. + Don't look for ReceiverDisconnectedException while creating the receiver since CreateReceiver doesn't throw it. * Adding unit test covering ReceiverDisconnectedException handling due to higher epoch receiver. * Bumping up EPH client version to 1.0.1 on dev branch (#118) * Fixing build break introduced with preview check-in. * Bumping up EPH client version to 1.0.1 on dev branch * Keeping sample readmes in sync with docs.microsoft.com * Fix invoke processor after receive timeout behavior (#124) * Update readme.md (#110) Fixed broken links. * EPH to deliver Enumerable.Empty instead of NULL when EventProcessorOptions.InvokeProcessorAfterReceiveTimeout is set * Small refactoring to honor positive check. * Amqp create link should honor time left (#128) * Update readme.md (#110) Fixed broken links. * AmqpSender and AmqpReceiver should honor tile left while creating AMQP link. * Remove unnecessary variable. * Receive handler should failfast on unhandled exception (#127) * Update readme.md (#110) Fixed broken links. * ReceiveHandler should failfast when an unhandled exception detected. Adding a unit test to cover error handling and recovery for EPH. * Remove unintentional internal modifier. * Trace receive handler exit w/ error. * Receive should not throw timeout exception (#130) * Update readme.md (#110) Fixed broken links. * ReceiveAsync call should return NULL instead of throwing System.TimeoutException * Unregister receive handler fix (#135) * Update readme.md (#110) Fixed broken links. * Unregistering receive handler shouldn't generate OperationCanceledException * Removing .Fork() comment * Remove ActiveClientManager from service client (#136) * Update readme.md (#110) Fixed broken links. * Code cleanup: Removing ActiveLinkManager from AmqpServiceClient * Fix empty lease race issue (#141) * Update readme.md (#110) Fixed broken links. * Handle race condition where downloaded empty-lease might be already LEASED by some other host. * Remove lease object from LeaseLostException (#143) * Remove Lease object from LeaseLostException * Use partition id from context. * ProcessorHost to close on ReceiverDisconnectedException (#137) * Update readme.md (#110) Fixed broken links. * Fault partition pump on ReceiverDisconnectedException only. * Moving samples to the azure-event-hubs repo (#142) * Moving samples to the azure-event-hubs repo * Fixes * EPH lease manager and checkpointing fixes and improvements (#117) * Fixing build break introduced with preview check-in. * Here is the list of the changes: + Moving Offset and SequenceNumbre to base class Lease.cs + AzureStorageCheckpointLeaseManager.cs to stop downloading lease at every checkpoint call. This was causing 2 hosts operating on the same lease for a while. + Set MaximumExecutionTime on renewRequestOptions used while renewing storage lease. + Throw LeaseLostException when lease is lost on operations like Renew and Update. + Updating interface ICheckpointManager to accept Lease while updating checkpoint. + Some Linq improvements at lease steal and balancing logics. + Updating multiple-hosts unit test to validate load balancing. * Set PartitionContext's SequenceNumber and Offset only before delivering the messages to the handler. * CheckpointAsync(EventData eventData) should not allow checkpointing if the suplied eventData is ahead of processed batch. * Add unit test to cover checkpointing messages in the middle of a batch. * Marking ICheckpointManager.UpdateCheckpointAsync(Checkpoint checkpoint) as obsolute * Fix: ReceiveHandler and PartitionPump should gracefully handle exceptions thrown at ProcessError callbacks. Adding a CIT to cover error cases in EPH. * HostShouldRecoverWhenProcessProcessEventsAsyncThrows unit test to unregister host at the end. * Cancelling swallow and trace change in ReceiveHandlerProcessErrorAsync(Exception error) * Remove unnecessary ExceptionHandled trace from EventSource. * + Removing Obsolete signature from ICheckpointManager. + TaskContinuationOptions.OnlyOnRanToCompletion while persisting lease. * Adding Obsolete ICheckpointManager.UpdateCheckpointAsync(Checkpoint checkpoint) back * Avoid TaskCancelledException from ContinueWith when blob call fails due to lease lost. (#145) * Update global.json (#147) Specifying .net core version for Appveyor build * Bumping up the Storage version to 8.1.1 (#149)
- Loading branch information