Searched refs:lastShard (Results 1 – 1 of 1) sorted by relevance
126 LastShardDetector lastShard = new LastShardDetector(); in shardConfig() local129 buildMainShardListeners(config, lastShard), expectedShard); in shardConfig()150 shardConfig.setConfigurationObject(LAST_SHARD_DETECTOR, lastShard); in shardConfig()171 shardConfig.setConfigurationObject(LAST_SHARD_DETECTOR, lastShard); in shardConfig()