Skip to content

Commit

Permalink
Set the node's connection string when creating a new raft server
Browse files Browse the repository at this point in the history
  • Loading branch information
jvshahid committed Oct 31, 2014
1 parent f9b3a27 commit bdcaef1
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion coordinator/raft_server.go
Original file line number Diff line number Diff line change
Expand Up @@ -384,7 +384,7 @@ func (s *RaftServer) startRaft() error {
// Initialize and start Raft server.
transporter := raft.NewHTTPTransporter("/raft", raft.DefaultElectionTimeout)
var err error
s.raftServer, err = raft.NewServer(s.name, s.path, transporter, s.clusterConfig, s.clusterConfig, "")
s.raftServer, err = raft.NewServer(s.name, s.path, transporter, s.clusterConfig, s.clusterConfig, s.config.RaftConnectionString())
if err != nil {
return err
}
Expand Down

0 comments on commit bdcaef1

Please sign in to comment.