support hosts and host interchangeably

This commit is contained in:
phact 2020-03-09 13:08:40 -04:00
parent 0d5fdc9794
commit f2825b7011

View File

@ -79,6 +79,11 @@ public class CQLSessionCache implements Shutdownable {
String[] contactPoints = activityDef.getParams().getOptionalString("host") String[] contactPoints = activityDef.getParams().getOptionalString("host")
.map(h -> h.split(",")).orElse(null); .map(h -> h.split(",")).orElse(null);
if (contactPoints == null) {
contactPoints = activityDef.getParams().getOptionalString("hosts")
.map(h -> h.split(",")).orElse(null);
}
if (contactPoints != null) { if (contactPoints != null) {
builder.addContactPoints(contactPoints); builder.addContactPoints(contactPoints);
}else if (scb.isEmpty()){ }else if (scb.isEmpty()){