private static final String NEW_CASSANDRA_SESSION_CREATED = "New Cassandra Session Created";
private static final String NEW_CASSANDRA_CLUSTER_OBJECT_CREATED = "New Cassandra Cluster Object Created";
private static final String NEW_CASSANDRA_SESSION = "New Cassandra Session";
+ private static final Object LOCK = new Object();
private static class ResetRequest {
//package on purpose
Cluster tempCluster = null;
Session tempSession = null;
try {
- synchronized(NEW_CASSANDRA_SESSION_CREATED) {
+ synchronized(LOCK) {
boolean reset = false;
for(ResetRequest r : resetDeque) {
if(r.session == session) {