@Nonnull
@Override
public SnowcastSequencer createSequencer(@Nonnull String sequencerName, @Nonnull SnowcastEpoch epoch,
@Min(128) @Max(8192) int maxLogicalNodeCount, short backupCount) {
SequencerDefinition definition = new SequencerDefinition(sequencerName, epoch, maxLogicalNodeCount, backupCount);
Operation operation = new CreateSequencerDefinitionOperation(definition);
SequencerDefinition realDefinition = invoke(operation, sequencerName);
if (!definition.equals(realDefinition)) {
throw exception(SnowcastIllegalStateException::new, SEQUENCER_ALREADY_REGISTERED);
}
return getOrCreateSequencerProvision(realDefinition).getSequencer();
}
NodeSequencerService.java 文件源码
java
阅读 24
收藏 0
点赞 0
评论 0
项目:snowcast
作者:
评论列表
文章目录