From 32dea64519e7520c2ce2ac44abf4ce5582e1c0d6 Mon Sep 17 00:00:00 2001 From: Alex Shvid Date: Mon, 11 Nov 2013 19:54:19 -0800 Subject: [PATCH] added to RingMember finals --- .../cassandra/core/CassandraTemplate.java | 7 +----- .../data/cassandra/vo/RingMember.java | 24 +++++++++++++------ 2 files changed, 18 insertions(+), 13 deletions(-) diff --git a/src/main/java/org/springframework/data/cassandra/core/CassandraTemplate.java b/src/main/java/org/springframework/data/cassandra/core/CassandraTemplate.java index 1a001ef06..961925dea 100644 --- a/src/main/java/org/springframework/data/cassandra/core/CassandraTemplate.java +++ b/src/main/java/org/springframework/data/cassandra/core/CassandraTemplate.java @@ -99,12 +99,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); } diff --git a/src/main/java/org/springframework/data/cassandra/vo/RingMember.java b/src/main/java/org/springframework/data/cassandra/vo/RingMember.java index 8fa56d8c3..19c6429fd 100644 --- a/src/main/java/org/springframework/data/cassandra/vo/RingMember.java +++ b/src/main/java/org/springframework/data/cassandra/vo/RingMember.java @@ -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(); + } }