com.amdocs.zusammen.plugin.statestore.cassandra

Class StateStoreImpl

java.lang.Object

com.amdocs.zusammen.plugin.statestore.cassandra.StateStoreImpl

All Implemented Interfaces:

HealthHelper, com.amdocs.zusammen.sdk.health.IHealthCheck, com.amdocs.zusammen.sdk.state.StateStore

public class StateStoreImpl
extends Object
implements com.amdocs.zusammen.sdk.state.StateStore, HealthHelper

Field Summary

Fields

Modifier and Type	Field and Description
static com.amdocs.zusammen.commons.log.ZusammenLogger	LOGGER

Fields inherited from interface com.amdocs.zusammen.plugin.statestore.cassandra.dao.HealthHelper

CASSANDRA_MODEL_NAME

Constructor Summary

Constructors

Constructor and Description
StateStoreImpl()

Method Summary

Modifier and Type	Method and Description
com.amdocs.zusammen.datatypes.response.Response<com.amdocs.zusammen.commons.health.data.HealthInfo>	checkHealth(com.amdocs.zusammen.datatypes.SessionContext sessionContext)
com.amdocs.zusammen.datatypes.response.Response<Void>	createElement(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.sdk.state.types.StateElement element)
com.amdocs.zusammen.datatypes.response.Response<Void>	createItem(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Id itemId, com.amdocs.zusammen.datatypes.item.Info itemInfo, Date creationTime)
com.amdocs.zusammen.datatypes.response.Response<Void>	createItemVersion(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Space space, com.amdocs.zusammen.datatypes.Id itemId, com.amdocs.zusammen.datatypes.Id baseVersionId, com.amdocs.zusammen.datatypes.Id versionId, com.amdocs.zusammen.datatypes.item.ItemVersionData data, Date creationTime)
com.amdocs.zusammen.datatypes.response.Response<Void>	deleteElement(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.sdk.state.types.StateElement element)
com.amdocs.zusammen.datatypes.response.Response<Void>	deleteItem(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Id itemId)
com.amdocs.zusammen.datatypes.response.Response<Void>	deleteItemVersion(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Space space, com.amdocs.zusammen.datatypes.Id itemId, com.amdocs.zusammen.datatypes.Id versionId)
com.amdocs.zusammen.datatypes.response.Response<com.amdocs.zusammen.sdk.state.types.StateElement>	getElement(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.item.ElementContext elementContext, com.amdocs.zusammen.datatypes.Id elementId)
com.amdocs.zusammen.datatypes.response.Response<com.amdocs.zusammen.datatypes.Namespace>	getElementNamespace(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Id itemId, com.amdocs.zusammen.datatypes.Id elementId)
com.amdocs.zusammen.datatypes.response.Response<com.amdocs.zusammen.datatypes.item.Item>	getItem(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Id itemId)
com.amdocs.zusammen.datatypes.response.Response<com.amdocs.zusammen.datatypes.item.ItemVersion>	getItemVersion(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Space space, com.amdocs.zusammen.datatypes.Id itemId, com.amdocs.zusammen.datatypes.Id versionId)
com.amdocs.zusammen.datatypes.response.Response<Boolean>	isElementExist(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.item.ElementContext elementContext, com.amdocs.zusammen.datatypes.Id elementId)
com.amdocs.zusammen.datatypes.response.Response<Boolean>	isItemExist(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Id itemId)
com.amdocs.zusammen.datatypes.response.Response<Boolean>	isItemVersionExist(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Space space, com.amdocs.zusammen.datatypes.Id itemId, com.amdocs.zusammen.datatypes.Id versionId)
com.amdocs.zusammen.datatypes.response.Response<Collection<com.amdocs.zusammen.sdk.state.types.StateElement>>	listElements(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.item.ElementContext elementContext, com.amdocs.zusammen.datatypes.Id elementId)
com.amdocs.zusammen.datatypes.response.Response<Collection<com.amdocs.zusammen.datatypes.item.Item>>	listItems(com.amdocs.zusammen.datatypes.SessionContext context)
com.amdocs.zusammen.datatypes.response.Response<Collection<com.amdocs.zusammen.datatypes.item.ItemVersion>>	listItemVersions(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Space space, com.amdocs.zusammen.datatypes.Id itemId)
com.amdocs.zusammen.datatypes.response.Response<Void>	updateElement(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.sdk.state.types.StateElement element)
com.amdocs.zusammen.datatypes.response.Response<Void>	updateItem(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Id itemId, com.amdocs.zusammen.datatypes.item.Info itemInfo, Date modificationTime)
com.amdocs.zusammen.datatypes.response.Response<Void>	updateItemModificationTime(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Id itemId, Date modificationTime)
com.amdocs.zusammen.datatypes.response.Response<Void>	updateItemVersion(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Space space, com.amdocs.zusammen.datatypes.Id itemId, com.amdocs.zusammen.datatypes.Id versionId, com.amdocs.zusammen.datatypes.item.ItemVersionData data, Date modificationTime)
com.amdocs.zusammen.datatypes.response.Response<Void>	updateItemVersionModificationTime(com.amdocs.zusammen.datatypes.SessionContext context, com.amdocs.zusammen.datatypes.Space space, com.amdocs.zusammen.datatypes.Id itemId, com.amdocs.zusammen.datatypes.Id versionId, Date modificationTime)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.amdocs.zusammen.plugin.statestore.cassandra.dao.HealthHelper

getKeepAliveDao

Field Detail

LOGGER

public static final com.amdocs.zusammen.commons.log.ZusammenLogger LOGGER

Constructor Detail

StateStoreImpl

public StateStoreImpl()

Method Detail

checkHealth

public com.amdocs.zusammen.datatypes.response.Response<com.amdocs.zusammen.commons.health.data.HealthInfo> checkHealth(com.amdocs.zusammen.datatypes.SessionContext sessionContext)

Specified by:

checkHealth in interface com.amdocs.zusammen.sdk.health.IHealthCheck

listItems

public com.amdocs.zusammen.datatypes.response.Response<Collection<com.amdocs.zusammen.datatypes.item.Item>> listItems(com.amdocs.zusammen.datatypes.SessionContext context)

Specified by:

listItems in interface com.amdocs.zusammen.sdk.state.StateStore

isItemExist

public com.amdocs.zusammen.datatypes.response.Response<Boolean> isItemExist(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                            com.amdocs.zusammen.datatypes.Id itemId)

Specified by:

isItemExist in interface com.amdocs.zusammen.sdk.state.StateStore

getItem

public com.amdocs.zusammen.datatypes.response.Response<com.amdocs.zusammen.datatypes.item.Item> getItem(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                                                        com.amdocs.zusammen.datatypes.Id itemId)

Specified by:

getItem in interface com.amdocs.zusammen.sdk.state.StateStore

createItem

public com.amdocs.zusammen.datatypes.response.Response<Void> createItem(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                        com.amdocs.zusammen.datatypes.Id itemId,
                                                                        com.amdocs.zusammen.datatypes.item.Info itemInfo,
                                                                        Date creationTime)

Specified by:

createItem in interface com.amdocs.zusammen.sdk.state.StateStore

updateItem

public com.amdocs.zusammen.datatypes.response.Response<Void> updateItem(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                        com.amdocs.zusammen.datatypes.Id itemId,
                                                                        com.amdocs.zusammen.datatypes.item.Info itemInfo,
                                                                        Date modificationTime)

Specified by:

updateItem in interface com.amdocs.zusammen.sdk.state.StateStore

deleteItem

public com.amdocs.zusammen.datatypes.response.Response<Void> deleteItem(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                        com.amdocs.zusammen.datatypes.Id itemId)

Specified by:

deleteItem in interface com.amdocs.zusammen.sdk.state.StateStore

updateItemModificationTime

public com.amdocs.zusammen.datatypes.response.Response<Void> updateItemModificationTime(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                                        com.amdocs.zusammen.datatypes.Id itemId,
                                                                                        Date modificationTime)

Specified by:

updateItemModificationTime in interface com.amdocs.zusammen.sdk.state.StateStore

listItemVersions

public com.amdocs.zusammen.datatypes.response.Response<Collection<com.amdocs.zusammen.datatypes.item.ItemVersion>> listItemVersions(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                                                                                    com.amdocs.zusammen.datatypes.Space space,
                                                                                                                                    com.amdocs.zusammen.datatypes.Id itemId)

Specified by:

listItemVersions in interface com.amdocs.zusammen.sdk.state.StateStore

isItemVersionExist

public com.amdocs.zusammen.datatypes.response.Response<Boolean> isItemVersionExist(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                                   com.amdocs.zusammen.datatypes.Space space,
                                                                                   com.amdocs.zusammen.datatypes.Id itemId,
                                                                                   com.amdocs.zusammen.datatypes.Id versionId)

Specified by:

isItemVersionExist in interface com.amdocs.zusammen.sdk.state.StateStore

getItemVersion

public com.amdocs.zusammen.datatypes.response.Response<com.amdocs.zusammen.datatypes.item.ItemVersion> getItemVersion(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                                                                      com.amdocs.zusammen.datatypes.Space space,
                                                                                                                      com.amdocs.zusammen.datatypes.Id itemId,
                                                                                                                      com.amdocs.zusammen.datatypes.Id versionId)

Specified by:

getItemVersion in interface com.amdocs.zusammen.sdk.state.StateStore

createItemVersion

public com.amdocs.zusammen.datatypes.response.Response<Void> createItemVersion(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                               com.amdocs.zusammen.datatypes.Space space,
                                                                               com.amdocs.zusammen.datatypes.Id itemId,
                                                                               com.amdocs.zusammen.datatypes.Id baseVersionId,
                                                                               com.amdocs.zusammen.datatypes.Id versionId,
                                                                               com.amdocs.zusammen.datatypes.item.ItemVersionData data,
                                                                               Date creationTime)

Specified by:

createItemVersion in interface com.amdocs.zusammen.sdk.state.StateStore

updateItemVersion

public com.amdocs.zusammen.datatypes.response.Response<Void> updateItemVersion(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                               com.amdocs.zusammen.datatypes.Space space,
                                                                               com.amdocs.zusammen.datatypes.Id itemId,
                                                                               com.amdocs.zusammen.datatypes.Id versionId,
                                                                               com.amdocs.zusammen.datatypes.item.ItemVersionData data,
                                                                               Date modificationTime)

Specified by:

updateItemVersion in interface com.amdocs.zusammen.sdk.state.StateStore

deleteItemVersion

public com.amdocs.zusammen.datatypes.response.Response<Void> deleteItemVersion(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                               com.amdocs.zusammen.datatypes.Space space,
                                                                               com.amdocs.zusammen.datatypes.Id itemId,
                                                                               com.amdocs.zusammen.datatypes.Id versionId)

Specified by:

deleteItemVersion in interface com.amdocs.zusammen.sdk.state.StateStore

updateItemVersionModificationTime

public com.amdocs.zusammen.datatypes.response.Response<Void> updateItemVersionModificationTime(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                                               com.amdocs.zusammen.datatypes.Space space,
                                                                                               com.amdocs.zusammen.datatypes.Id itemId,
                                                                                               com.amdocs.zusammen.datatypes.Id versionId,
                                                                                               Date modificationTime)

Specified by:

updateItemVersionModificationTime in interface com.amdocs.zusammen.sdk.state.StateStore

listElements

public com.amdocs.zusammen.datatypes.response.Response<Collection<com.amdocs.zusammen.sdk.state.types.StateElement>> listElements(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                                                                                  com.amdocs.zusammen.datatypes.item.ElementContext elementContext,
                                                                                                                                  com.amdocs.zusammen.datatypes.Id elementId)

Specified by:

listElements in interface com.amdocs.zusammen.sdk.state.StateStore

isElementExist

public com.amdocs.zusammen.datatypes.response.Response<Boolean> isElementExist(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                               com.amdocs.zusammen.datatypes.item.ElementContext elementContext,
                                                                               com.amdocs.zusammen.datatypes.Id elementId)

Specified by:

isElementExist in interface com.amdocs.zusammen.sdk.state.StateStore

getElementNamespace

public com.amdocs.zusammen.datatypes.response.Response<com.amdocs.zusammen.datatypes.Namespace> getElementNamespace(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                                                                    com.amdocs.zusammen.datatypes.Id itemId,
                                                                                                                    com.amdocs.zusammen.datatypes.Id elementId)

Specified by:

getElementNamespace in interface com.amdocs.zusammen.sdk.state.StateStore

getElement

public com.amdocs.zusammen.datatypes.response.Response<com.amdocs.zusammen.sdk.state.types.StateElement> getElement(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                                                                    com.amdocs.zusammen.datatypes.item.ElementContext elementContext,
                                                                                                                    com.amdocs.zusammen.datatypes.Id elementId)

Specified by:

getElement in interface com.amdocs.zusammen.sdk.state.StateStore

createElement

public com.amdocs.zusammen.datatypes.response.Response<Void> createElement(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                           com.amdocs.zusammen.sdk.state.types.StateElement element)

Specified by:

createElement in interface com.amdocs.zusammen.sdk.state.StateStore

updateElement

public com.amdocs.zusammen.datatypes.response.Response<Void> updateElement(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                           com.amdocs.zusammen.sdk.state.types.StateElement element)

Specified by:

updateElement in interface com.amdocs.zusammen.sdk.state.StateStore

deleteElement

public com.amdocs.zusammen.datatypes.response.Response<Void> deleteElement(com.amdocs.zusammen.datatypes.SessionContext context,
                                                                           com.amdocs.zusammen.sdk.state.types.StateElement element)

Specified by:

deleteElement in interface com.amdocs.zusammen.sdk.state.StateStore