From 66982c20b362a5ca80a46318b01be1df4d5aad82 Mon Sep 17 00:00:00 2001
From: serkar <serkar@SERKAR-DEVBOX1>
Date: Mon, 28 Nov 2016 14:44:04 -0800
Subject: [PATCH] .

---
 src/Microsoft.Azure.EventHubs.Processor/PartitionManager.cs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/Microsoft.Azure.EventHubs.Processor/PartitionManager.cs b/src/Microsoft.Azure.EventHubs.Processor/PartitionManager.cs
index c0b7d58..4ea4d01 100644
--- a/src/Microsoft.Azure.EventHubs.Processor/PartitionManager.cs
+++ b/src/Microsoft.Azure.EventHubs.Processor/PartitionManager.cs
@@ -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
                 {