+
+ private static class ShardManagerCreator implements Creator<ShardManager> {
+ private static final long serialVersionUID = 1L;
+
+ final String type;
+ final ClusterWrapper cluster;
+ final Configuration configuration;
+ final ShardContext shardContext;
+
+ ShardManagerCreator(String type, ClusterWrapper cluster,
+ Configuration configuration, ShardContext shardContext) {
+ this.type = type;
+ this.cluster = cluster;
+ this.configuration = configuration;
+ this.shardContext = shardContext;
+ }
+
+ @Override
+ public ShardManager create() throws Exception {
+ return new ShardManager(type, cluster, configuration, shardContext);
+ }
+ }