public void setContactPoints()

in cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/datasource/DataSource.java [180:210]

• 31 lines of code
• 9 McCabe index (conditional complexity)

    public void setContactPoints(String... points) {
        if (points == null || points.length == 0) {
            return;
        }
        for (String point : points) {
            if (point.contains(":")) {
                if (contactPointsWithPorts == null) {
                    contactPointsWithPorts = new LinkedList<>();
                }
                String[] chunks = point.split(":");
                try {
                    contactPointsWithPorts.add(InetSocketAddress.createUnresolved(chunks[0].trim(), Integer.parseInt(chunks[1].trim())));
                }
                catch (Throwable e) {
                    throw new IllegalArgumentException("Incorrect contact point '" + point + "' specified for Cassandra cache storage", e);
                }
            }
            else {
                if (contactPoints == null) {
                    contactPoints = new LinkedList<>();
                }
                try {
                    contactPoints.add(InetAddress.getByName(point));
                }
                catch (Throwable e) {
                    throw new IllegalArgumentException("Incorrect contact point '" + point + "' specified for Cassandra cache storage", e);
                }
            }
        }
        invalidate();
    }