Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

More test case fixes.

  • Loading branch information...
commit 82ad5797aa9f5bbdb470ff8b29017b3188600c95 1 parent 3dbf55b
@mevivs mevivs authored
View
1  .../test/java/com/impetus/client/cassandra/config/CassandraSchemaGenerationUsingXmlTest.java
@@ -43,6 +43,7 @@
public void setUp() throws Exception
{
CassandraCli.cassandraSetUp();
+ CassandraCli.createKeySpace(keyspaceName);
emf = Persistence.createEntityManagerFactory("CassandraXmlPropertyTest");
}
View
13 kundera-cassandra/src/test/java/com/impetus/client/persistence/CassandraCli.java
@@ -62,8 +62,6 @@
/** the log used by this class. */
private static Log log = LogFactory.getLog(CassandraCli.class);
-
- private static TSocket socket;
/**
* Cassandra set up.
*
@@ -213,14 +211,7 @@ public static void dropKeySpace(String keyspaceName)
catch (TException e)
{
log.error(e);
- } finally
- {
- if(socket != null)
- {
- socket.close();
- }
- }
-
+ }
}
private static void deleteCassandraFolders(String dir)
@@ -314,7 +305,7 @@ private static boolean checkIfServerRunning()
*/
public static void initClient() throws TTransportException
{
- socket = new TSocket("127.0.0.1", 9160);
+ TSocket socket = new TSocket("127.0.0.1", 9160);
TTransport transport = new TFramedTransport(socket);
TProtocol protocol = new TBinaryProtocol(transport);
client = new Cassandra.Client(protocol);
Please sign in to comment.
Something went wrong with that request. Please try again.