Spring/spring-data-cassandra
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of https://github.com/shvid/spring-data-cassandra.git into DATACASS-32

Browse Source
This commit is contained in:
dwebb
2013-11-12 00:59:15 -05:00
parent 9845659b89 32dea64519
commit b8120ccc71
2 changed files with 18 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/springframework/data/cassandra/core/CassandraTemplate.java
View File

@@ -131,12 +131,7 @@ public class CassandraTemplate implements CassandraOperations {
*/
for (Host h: hosts) {
member = new RingMember();
member.hostName = h.getAddress().getHostName();
member.address = h.getAddress().getHostAddress();
member.DC = h.getDatacenter();
member.rack = h.getRack();
member = new RingMember(h);
ring.add(member);
}

24
src/main/java/org/springframework/data/cassandra/vo/RingMember.java
View File

@@ -17,21 +17,31 @@ package org.springframework.data.cassandra.vo;
import java.io.Serializable;
import com.datastax.driver.core.Host;
/**
* @author David Webb
*
*/
public class RingMember implements Serializable {
public final class RingMember implements Serializable {
private static final long serialVersionUID = 1345346346L;
/*
* Ring attributes
*/
public String hostName;
public String address;
public String DC;
public String rack;
public String status;
public String state;
public final String hostName;
public final String address;
public final String DC;
public final String rack;
//public final String status;
//public final String state;
public RingMember(Host h) {
this.hostName = h.getAddress().getHostName();
this.address = h.getAddress().getHostAddress();
this.DC = h.getDatacenter();
this.rack = h.getRack();
}
}