Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-901: Fixed unit test to verify IP address of Cassandra contact point This closes #286 

Signed-off-by: Matt Gilman <matt.c.gilman@gmail.com>
This commit is contained in:
Matt Burgess 2016-03-17 13:46:53 -04:00 committed by Matt Gilman
parent 76f2d5702f
commit 94cf1beeba
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
nifi-nar-bundles/nifi-cassandra-bundle/nifi-cassandra-processors/src/test/java/org/apache/nifi/processors/cassandra/AbstractCassandraProcessorTest.java
View File

@ -175,13 +175,13 @@ public class AbstractCassandraProcessorTest {
contactPoints = processor.getContactPoints("192.168.99.100:9042"); contactPoints = processor.getContactPoints("192.168.99.100:9042");
assertNotNull(contactPoints); assertNotNull(contactPoints);
assertEquals(1, contactPoints.size()); assertEquals(1, contactPoints.size());
assertEquals("192.168.99.100", contactPoints.get(0).getHostName()); assertEquals("192.168.99.100", contactPoints.get(0).getAddress().getHostAddress());
assertEquals(9042, contactPoints.get(0).getPort()); assertEquals(9042, contactPoints.get(0).getPort());
contactPoints = processor.getContactPoints("192.168.99.100:9042, mydomain.com : 4000"); contactPoints = processor.getContactPoints("192.168.99.100:9042, mydomain.com : 4000");
assertNotNull(contactPoints); assertNotNull(contactPoints);
assertEquals(2, contactPoints.size()); assertEquals(2, contactPoints.size());
assertEquals("192.168.99.100", contactPoints.get(0).getHostName()); assertEquals("192.168.99.100", contactPoints.get(0).getAddress().getHostAddress());
assertEquals(9042, contactPoints.get(0).getPort()); assertEquals(9042, contactPoints.get(0).getPort());
assertEquals("mydomain.com", contactPoints.get(1).getHostName()); assertEquals("mydomain.com", contactPoints.get(1).getHostName());
assertEquals(4000, contactPoints.get(1).getPort()); assertEquals(4000, contactPoints.get(1).getPort());