org.apache.archiva.metadata.repository.cassandra

Class DefaultCassandraArchivaManager

java.lang.Object

org.apache.archiva.metadata.repository.cassandra.DefaultCassandraArchivaManager

All Implemented Interfaces:

CassandraArchivaManager

@Service(value="archivaEntityManagerFactory#cassandra")
public class DefaultCassandraArchivaManager
extends Object
implements CassandraArchivaManager

FIXME make all configuration not hardcoded :-)

Since:

2.0.0

Author:

Olivier Lamy

Field Summary

Fields

Modifier and Type	Field and Description
private org.springframework.context.ApplicationContext	applicationContext
private String	artifactMetadataFamilyName
private String	cassandraHost
private String	cassandraPort
private me.prettyprint.hector.api.Cluster	cluster
private static String	CLUSTER_NAME
private String	clusterName
private String	dependencyFamilyName
private me.prettyprint.hector.api.Keyspace	keyspace
private static String	KEYSPACE_NAME
private String	keyspaceName
private String	licenseFamilyName
private org.slf4j.Logger	logger
private String	mailingListFamilyName
private int	maxActive
private String	metadataFacetFamilyName
private String	namespaceFamilyName
private String	projectFamilyName
private String	projectVersionMetadataFamilyName
private String	readConsistencyLevel
private int	replicationFactor
private String	repositoryFamilyName
private RepositorySessionFactoryBean	repositorySessionFactoryBean
private boolean	started
private String	writeConsistencyLevel

Constructor Summary

Constructors

Constructor and Description
DefaultCassandraArchivaManager()

Method Summary

Modifier and Type	Method and Description
String	getArtifactMetadataFamilyName()
me.prettyprint.hector.api.Cluster	getCluster()
String	getDependencyFamilyName()
me.prettyprint.hector.api.Keyspace	getKeyspace()
String	getLicenseFamilyName()
String	getMailingListFamilyName()
String	getMetadataFacetFamilyName()
String	getNamespaceFamilyName()
String	getProjectFamilyName()
String	getProjectVersionMetadataFamilyName()
String	getRepositoryFamilyName()
void	initialize()
void	shutdown()
void	start()
boolean	started()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

private org.slf4j.Logger logger

applicationContext

@Inject
private org.springframework.context.ApplicationContext applicationContext

CLUSTER_NAME

private static final String CLUSTER_NAME

See Also:

Constant Field Values

KEYSPACE_NAME

private static final String KEYSPACE_NAME

See Also:

Constant Field Values

started

private boolean started

cluster

private me.prettyprint.hector.api.Cluster cluster

keyspace

private me.prettyprint.hector.api.Keyspace keyspace

repositoryFamilyName

private String repositoryFamilyName

namespaceFamilyName

private String namespaceFamilyName

projectFamilyName

private String projectFamilyName

projectVersionMetadataFamilyName

private String projectVersionMetadataFamilyName

artifactMetadataFamilyName

private String artifactMetadataFamilyName

metadataFacetFamilyName

private String metadataFacetFamilyName

mailingListFamilyName

private String mailingListFamilyName

licenseFamilyName

private String licenseFamilyName

dependencyFamilyName

private String dependencyFamilyName

cassandraHost

@Value(value="${cassandra.host}")
private String cassandraHost

cassandraPort

@Value(value="${cassandra.port}")
private String cassandraPort

maxActive

@Value(value="${cassandra.maxActive}")
private int maxActive

readConsistencyLevel

@Value(value="${cassandra.readConsistencyLevel}")
private String readConsistencyLevel

writeConsistencyLevel

@Value(value="${cassandra.writeConsistencyLevel}")
private String writeConsistencyLevel

replicationFactor

@Value(value="${cassandra.replicationFactor}")
private int replicationFactor

keyspaceName

@Value(value="${cassandra.keyspace.name}")
private String keyspaceName

clusterName

@Value(value="${cassandra.cluster.name}")
private String clusterName

repositorySessionFactoryBean

@Inject
private RepositorySessionFactoryBean repositorySessionFactoryBean

Constructor Detail

DefaultCassandraArchivaManager

public DefaultCassandraArchivaManager()

Method Detail

initialize

@PostConstruct
public void initialize()

start

public void start()

Specified by:

start in interface CassandraArchivaManager

shutdown

@PreDestroy
public void shutdown()

Specified by:

shutdown in interface CassandraArchivaManager

started

public boolean started()

Specified by:

started in interface CassandraArchivaManager

getKeyspace

public me.prettyprint.hector.api.Keyspace getKeyspace()

Specified by:

getKeyspace in interface CassandraArchivaManager

getCluster

public me.prettyprint.hector.api.Cluster getCluster()

Specified by:

getCluster in interface CassandraArchivaManager

getRepositoryFamilyName

public String getRepositoryFamilyName()

Specified by:

getRepositoryFamilyName in interface CassandraArchivaManager

getNamespaceFamilyName

public String getNamespaceFamilyName()

Specified by:

getNamespaceFamilyName in interface CassandraArchivaManager

getProjectFamilyName

public String getProjectFamilyName()

Specified by:

getProjectFamilyName in interface CassandraArchivaManager

getProjectVersionMetadataFamilyName

public String getProjectVersionMetadataFamilyName()

Specified by:

getProjectVersionMetadataFamilyName in interface CassandraArchivaManager

getArtifactMetadataFamilyName

public String getArtifactMetadataFamilyName()

Specified by:

getArtifactMetadataFamilyName in interface CassandraArchivaManager

getMetadataFacetFamilyName

public String getMetadataFacetFamilyName()

Specified by:

getMetadataFacetFamilyName in interface CassandraArchivaManager

getMailingListFamilyName

public String getMailingListFamilyName()

Specified by:

getMailingListFamilyName in interface CassandraArchivaManager

getLicenseFamilyName

public String getLicenseFamilyName()

Specified by:

getLicenseFamilyName in interface CassandraArchivaManager

getDependencyFamilyName

public String getDependencyFamilyName()

Specified by:

getDependencyFamilyName in interface CassandraArchivaManager