From 319934e9e4af28d3a9bbe9fdee8da4fba075a788 Mon Sep 17 00:00:00 2001 From: Harman Singh Date: Fri, 19 Sep 2014 17:28:58 -0700 Subject: [PATCH] Bug 1971 : Removing the bounded queue while actor creation to avoid issues in recovery Change-Id: I1c423ee0edf2a9b5bc9354f7ddc07150c700d4d3 Signed-off-by: Harman Singh --- .../controller/cluster/datastore/ShardManager.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardManager.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardManager.java index 5874c5296f..a8a1823809 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardManager.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ShardManager.java @@ -37,7 +37,6 @@ import org.opendaylight.controller.cluster.datastore.messages.PeerAddressResolve import org.opendaylight.controller.cluster.datastore.messages.PrimaryFound; import org.opendaylight.controller.cluster.datastore.messages.PrimaryNotFound; import org.opendaylight.controller.cluster.datastore.messages.UpdateSchemaContext; -import org.opendaylight.controller.cluster.datastore.utils.ActorContext; import org.opendaylight.yangtools.yang.model.api.ModuleIdentifier; import org.opendaylight.yangtools.yang.model.api.SchemaContext; import scala.concurrent.duration.Duration; @@ -307,8 +306,8 @@ public class ShardManager extends AbstractUntypedPersistentActor { ShardIdentifier shardId = getShardIdentifier(memberName, shardName); Map peerAddresses = getPeerAddresses(shardName); ActorRef actor = getContext() - .actorOf(Shard.props(shardId, peerAddresses, datastoreContext, schemaContext). - withMailbox(ActorContext.MAILBOX), shardId.toString()); + .actorOf(Shard.props(shardId, peerAddresses, datastoreContext, schemaContext), + shardId.toString()); localShardActorNames.add(shardId.toString()); localShards.put(shardName, new ShardInformation(shardName, actor, peerAddresses)); } -- 2.36.6