Cassandra session null à l'exécution

Question

J'ai le problème suivant: je veux faire une liste de modèles Cassandra à partir d'une liste de sessions. Cependant, le problème est qu'à l'exécution je comprends que l'objet de la session est nul. Le code i utilise est le suivant:

import java.util.ArrayList; 
import java.util.List; 

import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.beans.factory.annotation.Qualifier; 
import org.springframework.data.cassandra.config.CassandraClusterFactoryBean; 
import org.springframework.data.cassandra.config.CassandraSessionFactoryBean; 
import org.springframework.data.cassandra.config.SchemaAction; 
import org.springframework.data.cassandra.convert.CassandraConverter; 
import org.springframework.data.cassandra.core.CassandraOperations; 
import org.springframework.data.cassandra.core.CassandraTemplate; 
import org.springframework.stereotype.Component; 

@Component 
public class KeyspaceSession { 

    @Autowired 
    @Qualifier("cluster") 
    CassandraClusterFactoryBean cluster; 

    @Autowired 
    @Qualifier("converter") 
    CassandraConverter converter; 


    public List<CassandraOperations> getTemplates(){ 
     List<CassandraOperations> listOfTemplates = new ArrayList<>(); 
     for(CassandraKeyspaces keyspace : CassandraKeyspaces.values()){ 
      CassandraSessionFactoryBean session = new CassandraSessionFactoryBean(); 
      session.setCluster(cluster.getObject()); 
      session.setKeyspaceName(keyspace.getKeyspace()); 
      session.setConverter(converter); 
      session.setSchemaAction(SchemaAction.CREATE_IF_NOT_EXISTS); 
      CassandraOperations op = new CassandraTemplate(session.getObject()); 
      listOfTemplates.add(op); 
     } 
     return listOfTemplates; 
    } 

} 

Je reçois la réponse suivante du serveur:

{ 
    "timestamp": 1505204641753, 
    "status": 500, 
    "error": "Internal Server Error", 
    "exception": "java.lang.IllegalArgumentException", 
    "message": "Session must not be null", 
    "path": "/getUser/10/pl" 
} 

Answer 1

CassandraSessionFactoryBean nécessite une initialisation après avoir réglé toutes les propriétés. Appelez CassandraSessionFactoryBean.afterPropertiesSet() avant d'obtenir le Session. Vous devez également nettoyer les sessions lors de l'arrêt de l'application.

Idéalement, vous devez enregistrer BeanDefinition s pour chaque haricot Session et CassandraOperations que vous souhaitez créer.

Références:

• Add Bean Programmatically to Spring Web App Context
• How to Create Your Own 'Dynamic' Bean Definitions in Spring

Answer 2

Je n'ai pas travaillé avec le printemps avant alors pardonnez-moi si je me manque quelque chose. Mais je ne vois pas que vous définissez des points de contact, alors comment le pilote va savoir quel cluster à interroger?

Essayez ceci:

cluster.setContactPoints(<cassandra_server_ip>);