Searched refs:lastShard (Results 1 – 1 of 1) sorted by relevance
138 LastShardDetector lastShard = new LastShardDetector(); in shardConfig() local141 buildMainShardListeners(config, lastShard), expectedShard); in shardConfig()170 shardConfig.setConfigurationObject(LAST_SHARD_DETECTOR, lastShard); in shardConfig()192 shardConfig.setConfigurationObject(LAST_SHARD_DETECTOR, lastShard); in shardConfig()