org.apache.qpid.server.virtualhostnode.berkeleydb

Class BDBHAVirtualHostNodeImpl

java.lang.Object

org.apache.qpid.server.model.AbstractConfiguredObject<X>

org.apache.qpid.server.virtualhostnode.AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>

org.apache.qpid.server.virtualhostnode.berkeleydb.BDBHAVirtualHostNodeImpl

All Implemented Interfaces:

ConfiguredObject<BDBHAVirtualHostNodeImpl>, ContextProvider, PermissionedObject, TaskExecutorProvider, VirtualHostNode<BDBHAVirtualHostNodeImpl>, BDBEnvironmentContainer<BDBHAVirtualHostNodeImpl>, HASettings, FileBasedSettings, PreferencesRoot, PreferenceStoreProvider, Settings, BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl>, BDBVirtualHostNode<BDBHAVirtualHostNodeImpl>

public class BDBHAVirtualHostNodeImpl
extends AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>
implements BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException

Field Summary

Fields

Modifier and Type	Field and Description
static String	VIRTUAL_HOST_NODE_TYPE
static String	VIRTUAL_HOST_PRINCIPAL_NAME_FORMAT

Fields inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

SECURED_STRING_VALUE

Fields inherited from interface org.apache.qpid.server.virtualhostnode.berkeleydb.BDBHAVirtualHostNode

ADDRESS, DESIGNATED_PRIMARY, DURABILITY, GROUP_NAME, HELPER_ADDRESS, HELPER_NODE_NAME, JOIN_TIME, LAST_KNOWN_REPLICATION_TRANSACTION_ID, PERMITTED_NODES, PRIORITY, QUORUM_OVERRIDE, ROLE

Fields inherited from interface org.apache.qpid.server.virtualhostnode.berkeleydb.BDBVirtualHostNode

STORE_PATH

Fields inherited from interface org.apache.qpid.server.model.VirtualHostNode

DEFAULT_INITIAL_CONFIG_VIRTUALHOST_CONFIG_VAR, DEFAULT_INITIAL_CONFIGURATION, DEFAULT_VIRTUAL_HOST_NODE, QPID_INITIAL_CONFIG_VIRTUALHOST_CONFIG_VAR, VIRTUALHOST_BLUEPRINT_CONTEXT_VAR, VIRTUALHOST_INITIAL_CONFIGURATION

Fields inherited from interface org.apache.qpid.server.model.ConfiguredObject

AWAIT_ATTAINMENT_TIMEOUT, CONTEXT, CREATED_BY, CREATED_TIME, DEFAULT_AWAIT_ATTAINMENT_TIMEOUT, DESCRIPTION, DESIRED_STATE, DURABLE, ID, LAST_UPDATED_BY, LAST_UPDATED_TIME, LIFETIME_POLICY, NAME, OVER_SIZED_ATTRIBUTE_ALTERNATIVE_TEXT, STATE, TYPE

Constructor Summary

Constructors

Constructor and Description
BDBHAVirtualHostNodeImpl(Map<String,Object> attributes, Broker<?> broker)

Method Summary

Modifier and Type	Method and Description
protected com.google.common.util.concurrent.ListenableFuture<Void>	activate()
protected com.google.common.util.concurrent.ListenableFuture<Void>	beforeClose()
protected com.google.common.util.concurrent.ListenableFuture<Void>	beforeDelete()
void	checkpoint(boolean force)
int	cleanLog()
protected com.google.common.util.concurrent.ListenableFuture<Void>	closeVirtualHostIfExist()
protected DurableConfigurationStore	createConfigurationStore()
Map<String,Object>	databaseStatistics(String database, boolean reset)
protected com.google.common.util.concurrent.ListenableFuture<Void>	doStop()
protected ConfiguredObjectRecord	enrichInitialVirtualHostRootRecord(ConfiguredObjectRecord vhostRecord)
Map<String,Map<String,Object>>	environmentStatistics(boolean reset)
String	getAddress()
BDBConfigurationStore	getConfigurationStore()
EnvironmentFacade	getEnvironmentFacade()
String	getGroupName()
String	getHelperAddress()
String	getHelperNodeName()
Long	getJoinTime()
Long	getLastKnownReplicationTransactionId()
List<String>	getPermittedNodes()
PreferenceStore	getPreferenceStore()
int	getPriority()
int	getQuorumOverride()
Collection<? extends RemoteReplicationNode>	getRemoteReplicationNodes()
protected ReplicatedEnvironmentFacade	getReplicatedEnvironmentFacade()
NodeRole	getRole()
String	getStorePath()
static Map<String,Collection<String>>	getSupportedChildTypes()
boolean	isDesignatedPrimary()
protected com.google.common.util.concurrent.ListenableFuture<Void>	onClose()
void	onCreate()
protected com.google.common.util.concurrent.ListenableFuture<Void>	onDelete()
void	onOpen()
void	onValidate()
protected void	postResolve()
protected void	postSetPermittedNodes()
void	setBDBCacheSize(long cacheSize)
protected void	shutdownOnIntruder(String intruderHostAndPort)
String	toString()
Map<String,Object>	transactionStatistics(boolean reset)
void	updateMutableConfig()
protected void	validateChange(ConfiguredObject<?> proxyForValidation, Set<String> changedAttributes)
protected void	validateOnCreate()

Methods inherited from class org.apache.qpid.server.virtualhostnode.AbstractVirtualHostNode

closeVirtualHostIfExists, createPreferenceStore, doActivate, getBroker, getChildExecutor, getConfigurationStoreLogSubject, getEventLogger, getInitialConfigReader, getInitialRecords, getLifetimePolicy, getPreferenceStoreAttributes, getSupportedVirtualHostTypes, getVirtualHost, getVirtualHostInitialConfiguration, isDefaultVirtualHostNode, onCloseOrDelete, onExceptionInOpen, startQuiesced, stopAndSetStateTo

Methods inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

addChangeListener, addChildAsync, addFutureCallback, applyToChildren, asObjectRecord, attainState, attributeSet, authorise, authorise, authorise, authoriseCreateChild, awaitChildClassToAttainState, awaitChildClassToAttainState, changeAttributes, childAdded, childRemoved, close, closeAsync, closeChildren, create, createAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, deleteChildren, deleteNoChecks, doAfter, doAfter, doAfter, doAfter, doAfter, doAfter, doAfterAlways, doAfterAlways, doCreation, doOnConfigThread, doOpening, doResolution, doSync, doSync, doValidation, findConfiguredObject, forceUpdateAllSecureAttributes, getAccessControl, getActualAttributes, getAncestor, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildren, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getModel, getName, getObjectFactory, getParent, getState, getStatistics, getStatistics, getSubjectWithAddedSystemRights, getSystemPrincipal, getSystemTaskControllerContext, getSystemTaskSubject, getSystemTaskSubject, getTaskExecutor, getType, getTypeClass, getUserPreferences, handleExceptionOnOpen, hasEncrypter, isDurable, isSystemProcess, isSystemSubject, logOperation, managesChildStorage, newToken, notifyStateChanged, onResolve, open, openAsync, postResolveChildren, postSetAttributes, registerWithParents, removeChangeListener, removeContextVariable, rethrowRuntimeExceptionsOnOpen, runTask, setAttributes, setAttributesAsync, setContextVariable, setEncrypter, setState, setUserPreferences, start, startAsync, stop, updateModel, validateChildDelete

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.qpid.server.virtualhostnode.berkeleydb.BDBHAVirtualHostNode

getName

Methods inherited from interface org.apache.qpid.server.virtualhostnode.berkeleydb.BDBVirtualHostNode

getPreferenceStoreAttributes

Methods inherited from interface org.apache.qpid.server.model.VirtualHostNode

getVirtualHost, getVirtualHostInitialConfiguration, isDefaultVirtualHostNode, start, stop

Methods inherited from interface org.apache.qpid.server.store.preferences.PreferencesRoot

createPreferenceStore

Methods inherited from interface org.apache.qpid.server.model.ConfiguredObject

addChangeListener, asObjectRecord, authorise, authorise, authorise, close, closeAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, findConfiguredObject, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildExecutor, getChildren, getContext, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getLifetimePolicy, getModel, getObjectFactory, getParent, getState, getStatistics, getStatistics, getType, getTypeClass, getUserPreferences, hasEncrypter, isDurable, managesChildStorage, newToken, open, openAsync, removeChangeListener, removeContextVariable, setAttributes, setAttributesAsync, setContextVariable, setUserPreferences

Methods inherited from interface org.apache.qpid.server.model.ContextProvider

getContextKeys, getContextValue, getContextValue

Methods inherited from interface org.apache.qpid.server.model.TaskExecutorProvider

getTaskExecutor

Field Detail

VIRTUAL_HOST_NODE_TYPE

public static final String VIRTUAL_HOST_NODE_TYPE

See Also:

Constant Field Values

VIRTUAL_HOST_PRINCIPAL_NAME_FORMAT

public static final String VIRTUAL_HOST_PRINCIPAL_NAME_FORMAT

See Also:

Constant Field Values

Constructor Detail

BDBHAVirtualHostNodeImpl

public BDBHAVirtualHostNodeImpl(Map<String,Object> attributes,
                                Broker<?> broker)

Method Detail

validateChange

protected void validateChange(ConfiguredObject<?> proxyForValidation,
                              Set<String> changedAttributes)

Overrides:

validateChange in class AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>

getStorePath

public String getStorePath()

Specified by:

getStorePath in interface FileBasedSettings

Specified by:

getStorePath in interface BDBVirtualHostNode<BDBHAVirtualHostNodeImpl>

getGroupName

public String getGroupName()

Specified by:

getGroupName in interface HASettings

Specified by:

getGroupName in interface BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl>

getHelperAddress

public String getHelperAddress()

Specified by:

getHelperAddress in interface HASettings

Specified by:

getHelperAddress in interface BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl>

getAddress

public String getAddress()

Specified by:

getAddress in interface HASettings

Specified by:

getAddress in interface BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl>

isDesignatedPrimary

public boolean isDesignatedPrimary()

Specified by:

isDesignatedPrimary in interface HASettings

Specified by:

isDesignatedPrimary in interface BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl>

getPriority

public int getPriority()

Specified by:

getPriority in interface HASettings

Specified by:

getPriority in interface BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl>

getQuorumOverride

public int getQuorumOverride()

Specified by:

getQuorumOverride in interface HASettings

Specified by:

getQuorumOverride in interface BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl>

getRole

public NodeRole getRole()

Specified by:

getRole in interface BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl>

getLastKnownReplicationTransactionId

public Long getLastKnownReplicationTransactionId()

Specified by:

getLastKnownReplicationTransactionId in interface BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl>

getJoinTime

public Long getJoinTime()

Specified by:

getJoinTime in interface BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl>

getHelperNodeName

public String getHelperNodeName()

Specified by:

getHelperNodeName in interface HASettings

Specified by:

getHelperNodeName in interface BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl>

getPermittedNodes

public List<String> getPermittedNodes()

Specified by:

getPermittedNodes in interface BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl>

getRemoteReplicationNodes

public Collection<? extends RemoteReplicationNode> getRemoteReplicationNodes()

Specified by:

getRemoteReplicationNodes in interface VirtualHostNode<BDBHAVirtualHostNodeImpl>

toString

public String toString()

Overrides:

toString in class AbstractConfiguredObject<BDBHAVirtualHostNodeImpl>

getConfigurationStore

public BDBConfigurationStore getConfigurationStore()

Specified by:

getConfigurationStore in interface VirtualHostNode<BDBHAVirtualHostNodeImpl>

Overrides:

getConfigurationStore in class AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>

onCreate

public void onCreate()

Overrides:

onCreate in class AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>

onOpen

public void onOpen()

Overrides:

onOpen in class AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>

getReplicatedEnvironmentFacade

protected ReplicatedEnvironmentFacade getReplicatedEnvironmentFacade()

createConfigurationStore

protected DurableConfigurationStore createConfigurationStore()

Specified by:

createConfigurationStore in class AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>

activate

protected com.google.common.util.concurrent.ListenableFuture<Void> activate()

Specified by:

activate in class AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>

doStop

protected com.google.common.util.concurrent.ListenableFuture<Void> doStop()

Overrides:

doStop in class AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>

beforeDelete

protected com.google.common.util.concurrent.ListenableFuture<Void> beforeDelete()

Overrides:

beforeDelete in class AbstractConfiguredObject<BDBHAVirtualHostNodeImpl>

onDelete

protected com.google.common.util.concurrent.ListenableFuture<Void> onDelete()

Overrides:

onDelete in class AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>

onClose

protected com.google.common.util.concurrent.ListenableFuture<Void> onClose()

Overrides:

onClose in class AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>

postResolve

protected void postResolve()

Overrides:

postResolve in class AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>

validateOnCreate

protected void validateOnCreate()

Overrides:

validateOnCreate in class AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>

onValidate

public void onValidate()

Overrides:

onValidate in class AbstractConfiguredObject<BDBHAVirtualHostNodeImpl>

closeVirtualHostIfExist

protected com.google.common.util.concurrent.ListenableFuture<Void> closeVirtualHostIfExist()

beforeClose

protected com.google.common.util.concurrent.ListenableFuture<Void> beforeClose()

Overrides:

beforeClose in class AbstractConfiguredObject<BDBHAVirtualHostNodeImpl>

setBDBCacheSize

public void setBDBCacheSize(long cacheSize)

Specified by:

setBDBCacheSize in interface BDBEnvironmentContainer<BDBHAVirtualHostNodeImpl>

getPreferenceStore

public PreferenceStore getPreferenceStore()

Specified by:

getPreferenceStore in interface PreferenceStoreProvider

enrichInitialVirtualHostRootRecord

protected ConfiguredObjectRecord enrichInitialVirtualHostRootRecord(ConfiguredObjectRecord vhostRecord)

Specified by:

enrichInitialVirtualHostRootRecord in class AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl>

postSetPermittedNodes

protected void postSetPermittedNodes()

shutdownOnIntruder

protected void shutdownOnIntruder(String intruderHostAndPort)

updateMutableConfig

public void updateMutableConfig()

Specified by:

updateMutableConfig in interface BDBEnvironmentContainer<BDBHAVirtualHostNodeImpl>

cleanLog

public int cleanLog()

Specified by:

cleanLog in interface BDBEnvironmentContainer<BDBHAVirtualHostNodeImpl>

checkpoint

public void checkpoint(boolean force)

Specified by:

checkpoint in interface BDBEnvironmentContainer<BDBHAVirtualHostNodeImpl>

environmentStatistics

public Map<String,Map<String,Object>> environmentStatistics(boolean reset)

Specified by:

environmentStatistics in interface BDBEnvironmentContainer<BDBHAVirtualHostNodeImpl>

transactionStatistics

public Map<String,Object> transactionStatistics(boolean reset)

Specified by:

transactionStatistics in interface BDBEnvironmentContainer<BDBHAVirtualHostNodeImpl>

databaseStatistics

public Map<String,Object> databaseStatistics(String database,
                                             boolean reset)

Specified by:

databaseStatistics in interface BDBEnvironmentContainer<BDBHAVirtualHostNodeImpl>

getEnvironmentFacade

public EnvironmentFacade getEnvironmentFacade()

Specified by:

getEnvironmentFacade in interface BDBEnvironmentContainer<BDBHAVirtualHostNodeImpl>

getSupportedChildTypes

public static Map<String,Collection<String>> getSupportedChildTypes()