Correctly pass configured port to Connection

Fixes #35
2013-09-18 17:06:30 -05:00
parent 54699cbc04
commit 25f8314999
1 changed files with 2 additions and 0 deletions
--- a/cassandra/cluster.py
+++ b/cassandra/cluster.py
@@ -313,6 +313,7 @@ class Cluster(object):
        if self.auth_provider:
            kwargs['credentials'] = self.auth_provider(address)

+        kwargs['port'] = self.port
        kwargs['compression'] = self.compression
        kwargs['sockopts'] = self.sockopts

@@ -322,6 +323,7 @@ class Cluster(object):
        if self.auth_provider:
            kwargs['credentials'] = self.auth_provider(host)

+        kwargs['port'] = self.port
        kwargs['compression'] = self.compression
        kwargs['sockopts'] = self.sockopts