From a460a7a8ff47fb0bb790a2e2c041df94cf326e88 Mon Sep 17 00:00:00 2001
From: Patrik Nordwall <patrik.nordwall@gmail.com>
Date: Wed, 1 Apr 2015 15:04:29 +0200
Subject: [PATCH] =con #15817 add missing cancel of scheduled sharding task

---
 .../main/scala/akka/contrib/pattern/ClusterSharding.scala   | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/akka-contrib/src/main/scala/akka/contrib/pattern/ClusterSharding.scala b/akka-contrib/src/main/scala/akka/contrib/pattern/ClusterSharding.scala
index 5cc5b9bf54..fdaa3aa900 100644
--- a/akka-contrib/src/main/scala/akka/contrib/pattern/ClusterSharding.scala
+++ b/akka-contrib/src/main/scala/akka/contrib/pattern/ClusterSharding.scala
@@ -1029,6 +1029,11 @@ private[akka] class Shard(
 
   var handOffStopper: Option[ActorRef] = None
 
+  override def postStop(): Unit = {
+    super.postStop()
+    snapshotTask.cancel()
+  }
+
   def totalBufferSize = messageBuffers.foldLeft(0) { (sum, entry) ⇒ sum + entry._2.size }
 
   def processChange[A](event: A)(handler: A ⇒ Unit): Unit =
@@ -1586,6 +1591,7 @@ class ShardCoordinator(handOffTimeout: FiniteDuration, shardStartTimeout: Finite
   override def postStop(): Unit = {
     super.postStop()
     rebalanceTask.cancel()
+    snapshotTask.cancel()
   }
 
   override def receiveRecover: Receive = {