Author: [email protected]
Date: Fri Feb 17 13:27:30 2012
New Revision: 2099
Log:
[AMDATUCASSANDRA-164] Changed start/updated methods to synchronized, preventing
possible concurrency issues
Modified:
trunk/amdatu-cassandra/cassandra-persistencemanager-hector/src/main/java/org/amdatu/cassandra/persistencemanager/hector/service/HectorCassandraPersistenceManagerImpl.java
Modified:
trunk/amdatu-cassandra/cassandra-persistencemanager-hector/src/main/java/org/amdatu/cassandra/persistencemanager/hector/service/HectorCassandraPersistenceManagerImpl.java
==============================================================================
---
trunk/amdatu-cassandra/cassandra-persistencemanager-hector/src/main/java/org/amdatu/cassandra/persistencemanager/hector/service/HectorCassandraPersistenceManagerImpl.java
(original)
+++
trunk/amdatu-cassandra/cassandra-persistencemanager-hector/src/main/java/org/amdatu/cassandra/persistencemanager/hector/service/HectorCassandraPersistenceManagerImpl.java
Fri Feb 17 13:27:30 2012
@@ -147,7 +147,7 @@
private ConfigurationUtil m_configUtil;
private CassandraHostConfigurator m_hostConfig = null;
- public void start() {
+ public synchronized void start() {
super.start();
m_configUtil = new ConfigurationUtil(getLogService());
@@ -163,7 +163,7 @@
Logger.getLogger("me.prettyprint.cassandra.hector.TimingLogger").setLevel(Level.WARNING);
}
- public void updated(Dictionary dictionary) throws ConfigurationException {
+ public synchronized void updated(Dictionary dictionary) throws
ConfigurationException {
if (m_config == null) {
// This is just initialization of the configuration
m_config = dictionary;
_______________________________________________
Amdatu-commits mailing list
[email protected]
http://lists.amdatu.org/mailman/listinfo/amdatu-commits
