com.aquenos.cassandra.pvarchiver.server.spring

Class ArchiveServerApplicationConfiguration

java.lang.Object

com.aquenos.cassandra.pvarchiver.server.spring.ArchiveServerApplicationConfiguration

@Configuration
 @EnableConfigurationProperties(value={CassandraProperties.class,DevelopmentModeProperties.class,ServerProperties.class})
 @EnableMBeanExport
public class ArchiveServerApplicationConfiguration
extends Object

Configuration for the ApplicationContext created by the ArchiveServerApplication. The configuration has been separated into this class in order to keep it simple and not clutter it with all the static methods that the main application class needs for preparing the application context.

Author:

Sebastian Marsching

Constructor Summary

Constructors

Constructor and Description
ArchiveServerApplicationConfiguration()

Method Summary

Modifier and Type	Method and Description
ArchiveAccessService	archiveAccessService() Creates the archive access service.
ArchiveConfigurationService	archiveConfigurationService() Creates the archive configuration service.
ArchiveUserDetailsManager	archiveUserDetailsManager() Creates the archive user-details manager.
ArchivingService	archivingService() Creates the archiving service.
AsyncClientHttpRequestFactory	asyncClientHttpRequestFactory() Creates the async client HTTP request factory.
BCryptPasswordEncoder	bCryptPasswordEncoder() Creates the password encoder used for encoding password with the BCrypt algorithm and to verify such password hashes.
CassandraProvider	cassandraProvider() Creates the Cassandra database provider.
ChannelInformationCache	channelInformationCache() Creates the channel information cache.
ChannelMetaDataDAO	channelMetaDataDAO() Creates the DAO for accessing channel meta-data.
ThrottlingCassandraProvider	channelMetaDataDAOCassandraProvider() Creates the Cassandra database provider used for the channelMetaDataDAO().
ClusterManagementService	clusterManagementService() Creates the cluster management service.
ClusterServersDAO	clusterServersDAO() Creates the DAO for accessing information about the archiving servers within the cluster.
ControlSystemSupportRegistry	controlSystemSupportRegistry() Creates the control-system support registry.
ThrottlingCassandraProvider	controlSystemSupportRegistryCassandraProvider() Creates the Cassandra database provider used for the controlSystemSupportRegistry().
GenericDataStoreDAO	genericDataStoreDAO() Creates the DAO for accessing the generic data store.
InterNodeCommunicationAuthenticationService	interNodeCommunicationAuthenticationService() Creates the inter-node-communication authentication service.
InterNodeCommunicationService	interNodeCommunicationService() Creates the inter-node communication service.
ThrottlingProperties	throttlingProperties() Creates the throttling properties.

Methods inherited from class java.lang.Object

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

Constructor Detail

ArchiveServerApplicationConfiguration

public ArchiveServerApplicationConfiguration()

Method Detail

archiveAccessService

@Bean
public ArchiveAccessService archiveAccessService()

Creates the archive access service. The archive access service provides access to samples stored in the archive.

Returns:

archive access service.

archiveConfigurationService

@Bean
public ArchiveConfigurationService archiveConfigurationService()

Creates the archive configuration service. The archive configuration service takes care of processing requests to modify the archive configuration.

Returns:

archive configuration service.

archiveUserDetailsManager

@Bean
public ArchiveUserDetailsManager archiveUserDetailsManager()

Creates the archive user-details manager. This manager takes care of retrieving user details from the database for authentication and also allows user information stored inside the database to be modified.

Returns:

archive user-details manager.

archivingService

@Bean
public ArchivingService archivingService()

Creates the archiving service. The archiving service is responsible for the actual archiving (creating control-system channels, processing new samples, etc.).

Returns:

archiving service.

asyncClientHttpRequestFactory

@Bean
public AsyncClientHttpRequestFactory asyncClientHttpRequestFactory()

Creates the async client HTTP request factory. This factory is used for making asynchronous requests to HTTP servers. In particular, it is used by the inter-node communication service (see interNodeCommunicationService()).

Returns:

async client HTTP request factory.

bCryptPasswordEncoder

@Bean
public BCryptPasswordEncoder bCryptPasswordEncoder()

Creates the password encoder used for encoding password with the BCrypt algorithm and to verify such password hashes. This is the password encoder that is also used by the archiveUserDetailsManager().

Returns:

BCrypt password encoder.

cassandraProvider

@Bean
 @Primary
public CassandraProvider cassandraProvider()

Creates the Cassandra database provider. This provider provides the Cluster and Session objects through which the Cassandra database can be accessed. This bean is annotated with @Primary so that this Cassandra provider is used for autowiring.

Returns:

Cassandra provider bean.

channelInformationCache

@Bean
public ChannelInformationCache channelInformationCache()

Creates the channel information cache. The channel information cache stores channel information objects for all cluster channels in memory. This way, queries for these objects can be processed quickly without having to query the database.

Returns:

channel information cache.

clusterManagementService

@Bean
public ClusterManagementService clusterManagementService()

Creates the cluster management service. The cluster management service takes care of managing this server's state within the cluster.

Returns:

cluster manager.

channelMetaDataDAOCassandraProvider

@Bean
public ThrottlingCassandraProvider channelMetaDataDAOCassandraProvider()

Creates the Cassandra database provider used for the channelMetaDataDAO(). This provider is a throttling Cassandra provider that wraps the cassandraProvider(). The throttling is configured with the values specified by the throttlingProperties().

Returns:

Cassandra provider bean used by the the channelMetaDataDAO().

channelMetaDataDAO

@Bean
public ChannelMetaDataDAO channelMetaDataDAO()

Creates the DAO for accessing channel meta-data.

Returns:

channel meta-data DAO.

clusterServersDAO

@Bean
public ClusterServersDAO clusterServersDAO()

Creates the DAO for accessing information about the archiving servers within the cluster.

Returns:

cluster-servers DAO.

controlSystemSupportRegistryCassandraProvider

@Bean
public ThrottlingCassandraProvider controlSystemSupportRegistryCassandraProvider()

Creates the Cassandra database provider used for the controlSystemSupportRegistry(). This provider is a throttling Cassandra provider that wraps the cassandraProvider(). The throttling is configured with the values specified by the throttlingProperties().

Returns:

Cassandra provider bean used by the the controlSystemSupportRegistry().

controlSystemSupportRegistry

@Bean
public ControlSystemSupportRegistry controlSystemSupportRegistry()

Creates the control-system support registry. This registry is responsible for providing access to the various control-systems for which adapters are available in the class path.

Returns:

control-system support registry bean.

genericDataStoreDAO

@Bean
public GenericDataStoreDAO genericDataStoreDAO()

Creates the DAO for accessing the generic data store. The generic data store can be used by other components to share arbitrary information (as long as the data size is not too large) within the cluster.

Returns:

generic data store DAO.

interNodeCommunicationAuthenticationService

@Bean
public InterNodeCommunicationAuthenticationService interNodeCommunicationAuthenticationService()

Creates the inter-node-communication authentication service. The inter-node-communication authentication service takes care of authenticating requests toe the InterNodeCommunicationService. It provides methods for generating credentials that can then be checked by another instance of the service on a different host.

Returns:

inter-node-communication authentication service.

interNodeCommunicationService

@Bean
public InterNodeCommunicationService interNodeCommunicationService()

Creates the inter-node communication service. The inter-node communication service provides access to other (running) servers within the cluster.

Returns:

inter-node communication service.

throttlingProperties

@Bean
public ThrottlingProperties throttlingProperties()

Creates the throttling properties. The throttling properties specify the configuration options used by the channelMetaDataDAOCassandraProvider() and controlSystemSupportRegistryCassandraProvider(). This method only creates the object. The actual property values are injected by the Spring container.

Returns:

throttling configuration properties.