Package com.persequor.extension.db

Interface IConnectivityService

All Known Implementing Classes:

TestConnectivityService

public interface IConnectivityService

The service you inject into your code to access your backing services defined in your config interface implementations. SAGA will keep track of connections, pools, etc. such that these get opened and closed at the right points in time in respect of SAGA's boot up and shutdown procedures.

Method Summary

Modifier and Type	Method	Description
com.persequor.cassandra.Cassandra	cassandra(Class<? extends ICassandraDbConfig> configClass)	Get a connection to your Cassandra database configured in ICassandraDbConfig implementation.
com.datastax.oss.driver.api.core.CqlSession	cqlSession(Class<? extends ICassandraDbConfig> configClass)
Database	sql(Class<? extends ISqlDbConfig> configClass)	Get a connection to your sql database configured in ISqlDbConfig implementation.
IVolatileStore	volatileStore(Class<? extends IVolatileConfig> namespaceConfig)	Get a connection to your volatile store namespace configured in IVolatileConfig implementation.

Method Details

sql

Database sql(Class<? extends ISqlDbConfig> configClass)

Get a connection to your sql database configured in ISqlDbConfig implementation.

Parameters:

configClass - configuration class implementing ISqlDbConfig

Returns:

connection

cassandra

com.persequor.cassandra.Cassandra cassandra(Class<? extends ICassandraDbConfig> configClass)

Get a connection to your Cassandra database configured in ICassandraDbConfig implementation.

Parameters:

configClass - configuration class implementing ICassandraDbConfig

Returns:

connection

cqlSession

com.datastax.oss.driver.api.core.CqlSession cqlSession(Class<? extends ICassandraDbConfig> configClass)

volatileStore

IVolatileStore volatileStore(Class<? extends IVolatileConfig> namespaceConfig)

Get a connection to your volatile store namespace configured in IVolatileConfig implementation.

Parameters:

namespaceConfig - configuration class implementing IVolatileConfig

Returns:

connection