- this.distributedDataStore = Preconditions.checkNotNull(distributedDataStore);
- this.client = Preconditions.checkNotNull(client);
- this.shardRoot = Preconditions.checkNotNull(shardRoot);
+ this.client = requireNonNull(client);
+ this.shardRoot = requireNonNull(shardRoot);
+
+ publisher = new DistributedShardChangePublisher(client, requireNonNull(distributedDataStore), shardRoot,
+ childShards);