diff --git a/src/main/java/org/gcube/portal/databook/server/CassandraClusterConnection.java b/src/main/java/org/gcube/portal/databook/server/CassandraClusterConnection.java
index d982f2d..663c933 100644
--- a/src/main/java/org/gcube/portal/databook/server/CassandraClusterConnection.java
+++ b/src/main/java/org/gcube/portal/databook/server/CassandraClusterConnection.java
@@ -267,6 +267,8 @@ public class CassandraClusterConnection {
 		ColumnFamilyDefinition cfDefUserNotifications = getDynamicCFDef(DBCassandraAstyanaxImpl.USER_NOTIFICATIONS);
 		ColumnFamilyDefinition cfDefUserNotificationsUnread = getDynamicCFDef(DBCassandraAstyanaxImpl.USER_NOTIFICATIONS_UNREAD);
 		ColumnFamilyDefinition cfDefUserNotificationsPreferences = getDynamicCFDef(DBCassandraAstyanaxImpl.USER_NOTIFICATIONS_PREFERENCES);
+		ColumnFamilyDefinition cfDefEmailInvitesTimeline = getDynamicCFDef(DBCassandraAstyanaxImpl.EMAIL_INVITES);
+		ColumnFamilyDefinition cfDefVREInvitesTimeline = getDynamicCFDef(DBCassandraAstyanaxImpl.VRE_INVITES);
 		ColumnFamilyDefinition cfDefHashtagsCounter = getDynamicCFDef(DBCassandraAstyanaxImpl.HASHTAGS_COUNTER);
 		ColumnFamilyDefinition cfDefHashtagTimeline = getDynamicCFDef(DBCassandraAstyanaxImpl.HASHTAGGED_FEEDS);
 
@@ -289,6 +291,8 @@ public class CassandraClusterConnection {
 		.addColumnFamily(cfDefUserNotificationsUnread)
 		.addColumnFamily(cfDefUserNotificationsPreferences)
 		.addColumnFamily(cfDefUserLikedFeeds)
+		.addColumnFamily(cfDefEmailInvitesTimeline)
+		.addColumnFamily(cfDefVREInvitesTimeline)
 		.addColumnFamily(cfDefHashtagsCounter)
 		.addColumnFamily(cfDefHashtagTimeline);
 
diff --git a/src/main/java/org/gcube/portal/databook/server/DatabookCassandraTest.java b/src/main/java/org/gcube/portal/databook/server/DatabookCassandraTest.java
index 5f6a402..5ef1f80 100644
--- a/src/main/java/org/gcube/portal/databook/server/DatabookCassandraTest.java
+++ b/src/main/java/org/gcube/portal/databook/server/DatabookCassandraTest.java
@@ -1,6 +1,12 @@
 package org.gcube.portal.databook.server;
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
+import org.junit.Test;
+
+import com.google.common.collect.ImmutableMap;
+import com.netflix.astyanax.connectionpool.exceptions.ConnectionException;
+import com.netflix.astyanax.model.ColumnFamily;
+import com.netflix.astyanax.serializers.StringSerializer;
 
 public class DatabookCassandraTest {
 	private static DBCassandraAstyanaxImpl store;
@@ -318,30 +324,30 @@ public class DatabookCassandraTest {
 	//	}
 
 
-	//		/**
-	//		 * use exclusively to add a new (Dynamic) CF to a keyspace
-	//		 */
-	//		@Test
-	//		public void addInvitesDynamicColumnFamilies() {
-	//			System.out.println("UserNotificationsUnread");
-	//			ColumnFamily<String, String> cf_UserNotificationsUnreadTimeline =	new ColumnFamily<String, String>(
-	//					DBCassandraAstyanaxImpl.USER_NOTIFICATIONS_UNREAD,  // Column Family Name
-	//					StringSerializer.get(),   // Key Serializer
-	//					StringSerializer.get());  // Column Serializer
-	//	
-	//			try {
-	//			
-	//				new CassandraClusterConnection(false).getKeyspace().createColumnFamily(cf_UserNotificationsUnreadTimeline, ImmutableMap.<String, Object>builder()
-	//						.put("default_validation_class", "UTF8Type")
-	//						.put("key_validation_class",     "UTF8Type")
-	//						.put("comparator_type",          "UTF8Type")
-	//						.build());
-	//				
-	//			} catch (ConnectionException e) {
-	//				e.printStackTrace();
-	//			}
-	//			System.out.println("UserNotificationsUnread END");
-	//		}
+//			/**
+//			 * use exclusively to add a new (Dynamic) CF to a keyspace
+//			 */
+//			@Test
+//			public void addInvitesDynamicColumnFamilies() {
+//				System.out.println("UserNotificationsUnread");
+//				ColumnFamily<String, String> cf_UserNotificationsUnreadTimeline =	new ColumnFamily<String, String>(
+//						DBCassandraAstyanaxImpl.EMAIL_INVITES,  // Column Family Name
+//						StringSerializer.get(),   // Key Serializer
+//						StringSerializer.get());  // Column Serializer
+//		
+//				try {
+//				
+//					new CassandraClusterConnection(false).getKeyspace().createColumnFamily(cf_UserNotificationsUnreadTimeline, ImmutableMap.<String, Object>builder()
+//							.put("default_validation_class", "UTF8Type")
+//							.put("key_validation_class",     "UTF8Type")
+//							.put("comparator_type",          "UTF8Type")
+//							.build());
+//					
+//				} catch (ConnectionException e) {
+//					e.printStackTrace();
+//				}
+//				System.out.println("UserNotificationsUnread END");
+//			}
 
 
 	//	private List<String> getKeys() {