Author: [email protected]
Date: Mon Sep 26 17:00:47 2011
New Revision: 1417
Log:
[AMDATUCASSANDRA-97] Fixed by accepting null token secrets in the cassandra
token store
Modified:
trunk/amdatu-cassandra/cassandra-store-token/src/main/java/org/amdatu/cassandra/store/token/service/CassandraTokenStorageProviderImpl.java
Modified:
trunk/amdatu-cassandra/cassandra-store-token/src/main/java/org/amdatu/cassandra/store/token/service/CassandraTokenStorageProviderImpl.java
==============================================================================
---
trunk/amdatu-cassandra/cassandra-store-token/src/main/java/org/amdatu/cassandra/store/token/service/CassandraTokenStorageProviderImpl.java
(original)
+++
trunk/amdatu-cassandra/cassandra-store-token/src/main/java/org/amdatu/cassandra/store/token/service/CassandraTokenStorageProviderImpl.java
Mon Sep 26 17:00:47 2011
@@ -99,13 +99,15 @@
public void addToken(final Token token) {
// We use the token also as row key
String rowKey = token.getToken();
- m_pm.setValue(CF_TOKEN, rowKey, null, C_SECRET,
token.getTokenSecret());
+ if (token.getTokenSecret() != null) {
+ m_pm.setValue(CF_TOKEN, rowKey, null, C_SECRET,
token.getTokenSecret());
+ }
m_pm.setValue(CF_TOKEN, rowKey, null, C_TIMESTAMP, new
Long(token.getTimestamp()).toString());
m_pm.setValue(CF_TOKEN, rowKey, null, C_PROPERTIES,
mapToString(token.getProperties()));
}
public boolean hasToken(final String token) {
- String value = m_pm.getValue(CF_TOKEN, token, null, C_SECRET,
String.class);
+ String value = m_pm.getValue(CF_TOKEN, token, null, C_TIMESTAMP,
String.class);
return value != null;
}
_______________________________________________
Amdatu-commits mailing list
[email protected]
http://lists.amdatu.org/mailman/listinfo/amdatu-commits
