Traceback (most recent call last):
      File "/usr/lib/python2.6/dist-packages/twisted/python/log.py", line 84, in callWithLogger
        return callWithContext({"system": lp}, func, *args, **kw)
      File "/usr/lib/python2.6/dist-packages/twisted/python/log.py", line 69, in callWithContext
        return context.call({ILogContext: newCtx}, func, *args, **kw)
      File "/usr/lib/python2.6/dist-packages/twisted/python/context.py", line 59, in callWithContext
        return self.currentContext().callWithContext(ctx, func, *args, **kw)
      File "/usr/lib/python2.6/dist-packages/twisted/python/context.py", line 37, in callWithContext
        return func(*args,**kw)
    --- <exception caught here> ---
      File "/usr/lib/python2.6/dist-packages/twisted/internet/selectreactor.py", line 146, in _doReadOrWrite
        why = getattr(selectable, method)()
      File "/usr/lib/python2.6/dist-packages/twisted/internet/tcp.py", line 664, in doConnect
        self._connectDone()
      File "/usr/lib/python2.6/dist-packages/twisted/internet/tcp.py", line 667, in _connectDone
        self.protocol = self.connector.buildProtocol(self.getPeer())
      File "/usr/lib/python2.6/dist-packages/twisted/internet/base.py", line 1045, in buildProtocol
        return self.factory.buildProtocol(addr)
      File "/home/lucio/src/cassandra/Telephus/telephus/protocol.py", line 164, in buildProtocol
        keyspace=self.keyspace)
    exceptions.TypeError: __init__() got an unexpected keyword argument 'keyspace'


lucio@persephone:~/src/cassandra/Telephus$ git diff example.py
diff --git a/example.py b/example.py
index 02a785c..a1a3d82 100644
--- a/example.py
+++ b/example.py
@@ -1,5 +1,5 @@
 #!/usr/bin/python
-from telephus.protocol import ManagedCassandraClientFactory
+from telephus.protocol import ManagedCassandraClientFactory,  TBinaryProtocol
 from telephus.client import CassandraClient
 from telephus.cassandra.ttypes import ColumnPath, ColumnParent, Column, SuperColumn
 from twisted.internet import defer
@@ -55,6 +55,7 @@ if __name__ == '__main__':
     log.startLogging(sys.stdout)

     f = ManagedCassandraClientFactory()
+    f.protocol =  TBinaryProtocol.TBinaryProtocol
     c = CassandraClient(f, KEYSPACE)
     dostuff(c)
     reactor.connectTCP(HOST, PORT, f)