diff --git a/akka-amqp/src/main/scala/FaultTolerantConnectionActor.scala b/akka-amqp/src/main/scala/FaultTolerantConnectionActor.scala
index 486b2e1311..1901df3202 100644
--- a/akka-amqp/src/main/scala/FaultTolerantConnectionActor.scala
+++ b/akka-amqp/src/main/scala/FaultTolerantConnectionActor.scala
@@ -40,7 +40,6 @@ private[amqp] class FaultTolerantConnectionActor(connectionParameters: Connectio
       }
     }
     case ConnectionShutdown(cause) => {
-      disconnect
       if (cause.isHardError) {
         // connection error
         if (cause.isInitiatedByApplication) {