/*
         * Start raft node with shared rpc server:
         * return new RaftGroupService(groupId, endpoint, nodeOptions,
         *                             this.context.rpcServer(), true)
         *        .start(false)
         */
private Node initRaftNode() throws IOException {
        NodeOptions nodeOptions = this.context.nodeOptions();
        nodeOptions.setFsm(this.stateMachine);
        // TODO: When support sharding, groupId needs to be bound to shard Id
        String groupId = this.context.group();
        PeerId endpoint = this.context.endpoint();
        /*
         * Start raft node with shared rpc server:
         * return new RaftGroupService(groupId, endpoint, nodeOptions,
         *                             this.context.rpcServer(), true)
         *        .start(false)
         */
        return RaftServiceFactory.createAndInitRaftNode(groupId, endpoint,
                                                        nodeOptions);
    }
String groupId = this.context.group();
PeerId endpoint = this.context.endpoint();
/*
* Start raft node with shared rpc server:
* return new RaftGroupService(groupId, endpoint, nodeOptions,
* this.context.rpcServer(), true)
* .start(false)
*/
return RaftServiceFactory.createAndInitRaftNode(groupId, endpoint,
nodeOptions);
private Node initRaftNode() throws IOException {
NodeOptions nodeOptions = this.context.nodeOptions();
nodeOptions.setFsm(this.stateMachine);
// TODO: When support sharding, groupId needs to be bound to shard Id
String groupId = this.context.group();
PeerId endpoint = this.context.endpoint();
/*
* Start raft node with shared rpc server:
* return new RaftGroupService(groupId, endpoint, nodeOptions,
* this.context.rpcServer(), true)
* .start(false)
*/
return RaftServiceFactory.createAndInitRaftNode(groupId, endpoint,
nodeOptions);
}
private Node initRaftNode() throws IOException {
NodeOptions nodeOptions = this.context.nodeOptions();
nodeOptions.setFsm(this.stateMachine);
// TODO: When support sharding, groupId needs to be bound to shard Id
String groupId = this.context.group();
PeerId endpoint = this.context.endpoint();
/*
* Start raft node with shared rpc server:
* return new RaftGroupService(groupId, endpoint, nodeOptions,
* this.context.rpcServer(), true)
* .start(false)
*/
return RaftServiceFactory.createAndInitRaftNode(groupId, endpoint,
nodeOptions);
}