NodeSequencerService.java 文件源码

@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();
}