svn commit: r1179682 - /cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/jdbc/CassandraConnection.java

[jb...@apache.org]

Author: jbellis
Date: Thu Oct  6 16:08:58 2011
New Revision: 1179682

URL: http://svn.apache.org/viewvc?rev=1179682&view=rev
Log:
switch to NBHS to avoid Comparable requirement on Statements
patch by jbellis

Modified:
    cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/jdbc/CassandraConnection.java

Modified: cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/jdbc/CassandraConnection.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/jdbc/CassandraConnection.java?rev=1179682&r1=1179681&r2=1179682&view=diff
==============================================================================
--- cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/jdbc/CassandraConnection.java (original)
+++ cassandra/trunk/drivers/java/src/org/apache/cassandra/cql/jdbc/CassandraConnection.java Thu Oct  6 16:08:58 2011
@@ -25,7 +25,6 @@ import java.util.HashMap;
 import java.util.Map;
 import java.util.Properties;
 import java.util.Set;
-import java.util.concurrent.ConcurrentSkipListSet;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -37,6 +36,7 @@ import org.apache.thrift.protocol.TProto
 import org.apache.thrift.transport.TFramedTransport;
 import org.apache.thrift.transport.TSocket;
 import org.apache.thrift.transport.TTransport;
+import org.cliffc.high_scale_lib.NonBlockingHashSet;
 
 import static org.apache.cassandra.cql.jdbc.Utils.*;
 
@@ -66,7 +66,7 @@ class CassandraConnection extends Abstra
     /**
      * Set of all Statements that have been created by this connection
      */
-    private Set<Statement> statements = new ConcurrentSkipListSet<Statement>();
+    private Set<Statement> statements = new NonBlockingHashSet<Statement>();
 
     private Cassandra.Client client;
     private TTransport transport;