Skip to content

Commit

Permalink
made second start method of ShardRegionCreator also public;
Browse files Browse the repository at this point in the history
Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
  • Loading branch information
Stefan Maute committed Sep 8, 2022
1 parent 30e9a17 commit d120e8a
Showing 1 changed file with 11 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,17 @@ public static ActorRef start(final ActorSystem system, final String shardRegionN
return start(system, shardRegionName, props, extractor, clusterRole);
}

static ActorRef start(final ActorSystem system, final String shardRegionName, final Props props,
/**
* Create a shard region using a custom hand-off message.
*
* @param system The actor system.
* @param shardRegionName The shard region name.
* @param props Props of the sharded actors.
* @param extractor The shard region extractor.
* @param clusterRole The cluster role whose members will start this shard region.
* @return actor reference of the started shard region.
*/
public static ActorRef start(final ActorSystem system, final String shardRegionName, final Props props,
final ShardRegion.MessageExtractor extractor, final String clusterRole) {
final var clusterSharding = ClusterSharding.get(system);
final var settings = ClusterShardingSettings.create(system).withRole(clusterRole);
Expand Down

0 comments on commit d120e8a

Please sign in to comment.