Removing pump change, this is not supposed to be part of this PR.

This commit is contained in:
serkar 2016-11-28 12:27:37 -08:00
Родитель 9effcae189
Коммит 8f65000424
1 изменённых файлов: 2 добавлений и 1 удалений

Просмотреть файл

@ -315,8 +315,9 @@ namespace Microsoft.Azure.EventHubs.Processor
// There already is a pump. Make sure the pump is working and replace the lease.
if (capturedPump.PumpStatus == PartitionPumpStatus.Errored || capturedPump.IsClosing)
{
// The existing pump is bad. Remove it.
// The existing pump is bad. Remove it and create a new one.
await RemovePumpAsync(partitionId, CloseReason.Shutdown).ConfigureAwait(false);
await CreateNewPumpAsync(partitionId, lease).ConfigureAwait(false);
}
else
{