public abstract class AbstractVirtualHostNode<X extends AbstractVirtualHostNode<X>> extends AbstractConfiguredObject<X> implements VirtualHostNode<X>
AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException
SECURED_STRING_VALUE
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
CONTEXT, CREATED_BY, CREATED_TIME, DESCRIPTION, DESIRED_STATE, DURABLE, ID, LAST_UPDATED_BY, LAST_UPDATED_TIME, LIFETIME_POLICY, NAME, OVER_SIZED_ATTRIBUTE_ALTERNATIVE_TEXT, STATE, TYPE
Constructor and Description |
---|
AbstractVirtualHostNode(Broker<?> parent,
Map<String,Object> attributes) |
Modifier and Type | Method and Description |
---|---|
protected abstract com.google.common.util.concurrent.ListenableFuture<Void> |
activate() |
protected abstract DurableConfigurationStore |
createConfigurationStore() |
protected com.google.common.util.concurrent.ListenableFuture<Void> |
deleteVirtualHostIfExists() |
protected com.google.common.util.concurrent.ListenableFuture<Void> |
doActivate() |
protected com.google.common.util.concurrent.ListenableFuture<Void> |
doDelete() |
protected com.google.common.util.concurrent.ListenableFuture<Void> |
doStop() |
protected abstract ConfiguredObjectRecord |
enrichInitialVirtualHostRootRecord(ConfiguredObjectRecord vhostRecord) |
protected Broker<?> |
getBroker() |
TaskExecutor |
getChildExecutor() |
DurableConfigurationStore |
getConfigurationStore() |
protected MessageStoreLogSubject |
getConfigurationStoreLogSubject() |
protected EventLogger |
getEventLogger() |
protected Reader |
getInitialConfigReader() |
protected ConfiguredObjectRecord[] |
getInitialRecords() |
LifetimePolicy |
getLifetimePolicy()
Return the lifetime policy for the object
|
protected static Collection<String> |
getSupportedVirtualHostTypes(boolean includeProvided) |
VirtualHost<?,?,?> |
getVirtualHost() |
String |
getVirtualHostInitialConfiguration() |
boolean |
isDefaultVirtualHostNode() |
protected void |
onClose() |
protected void |
onCreate() |
protected void |
onExceptionInOpen(RuntimeException e)
Callback method to perform ConfiguredObject specific exception handling on exception in open.
|
void |
onOpen() |
protected void |
postResolve() |
protected com.google.common.util.concurrent.ListenableFuture<Void> |
stopAndSetStateTo(State stoppedState) |
protected void |
validateChange(ConfiguredObject<?> proxyForValidation,
Set<String> changedAttributes) |
protected void |
validateOnCreate() |
addChangeListener, addChildAsync, applyToChildren, asObjectRecord, attainState, attributeSet, authoriseCreate, authoriseCreateChild, authoriseDelete, authoriseSetAttributes, beforeClose, changeAttribute, changeAttributes, childAdded, childRemoved, close, closeAsync, closeChildren, create, createAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, deleted, doAfter, doAfter, doAfter, doAfter, doAfter, doAfter, doAfterAlways, doAfterAlways, doCreation, doOnConfigThread, doOpening, doResolution, doSync, doSync, doValidation, findConfiguredObject, forceUpdateAllSecureAttributes, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildren, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getModel, getName, getObjectFactory, getParent, getSecurityManager, getState, getStatistics, getTaskExecutor, getType, getTypeClass, handleExceptionOnOpen, isDurable, managesChildStorage, notifyStateChanged, onResolve, onValidate, open, openAsync, parentsMap, postResolveChildren, registerWithParents, removeChangeListener, rethrowRuntimeExceptionsOnOpen, runTask, setAttribute, setAttributes, setAttributesAsync, setEncrypter, setState, start, startAsync, stop, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getRemoteReplicationNodes, start, stop
addChangeListener, asObjectRecord, close, closeAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, findConfiguredObject, getActualAttributes, 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, getTaskExecutor, getType, getTypeClass, isDurable, managesChildStorage, open, openAsync, removeChangeListener, setAttribute, setAttributes, setAttributesAsync
public void onOpen()
onOpen
in class AbstractConfiguredObject<X extends AbstractVirtualHostNode<X>>
public TaskExecutor getChildExecutor()
getChildExecutor
in interface ConfiguredObject<X extends AbstractVirtualHostNode<X>>
getChildExecutor
in class AbstractConfiguredObject<X extends AbstractVirtualHostNode<X>>
public LifetimePolicy getLifetimePolicy()
ConfiguredObject
getLifetimePolicy
in interface ConfiguredObject<X extends AbstractVirtualHostNode<X>>
getLifetimePolicy
in class AbstractConfiguredObject<X extends AbstractVirtualHostNode<X>>
protected void onCreate()
onCreate
in class AbstractConfiguredObject<X extends AbstractVirtualHostNode<X>>
protected com.google.common.util.concurrent.ListenableFuture<Void> doActivate()
public VirtualHost<?,?,?> getVirtualHost()
getVirtualHost
in interface VirtualHostNode<X extends AbstractVirtualHostNode<X>>
protected void validateOnCreate()
validateOnCreate
in class AbstractConfiguredObject<X extends AbstractVirtualHostNode<X>>
protected void validateChange(ConfiguredObject<?> proxyForValidation, Set<String> changedAttributes)
validateChange
in class AbstractConfiguredObject<X extends AbstractVirtualHostNode<X>>
public DurableConfigurationStore getConfigurationStore()
getConfigurationStore
in interface VirtualHostNode<X extends AbstractVirtualHostNode<X>>
protected Broker<?> getBroker()
protected EventLogger getEventLogger()
protected MessageStoreLogSubject getConfigurationStoreLogSubject()
protected com.google.common.util.concurrent.ListenableFuture<Void> doDelete()
protected com.google.common.util.concurrent.ListenableFuture<Void> deleteVirtualHostIfExists()
protected com.google.common.util.concurrent.ListenableFuture<Void> doStop()
protected com.google.common.util.concurrent.ListenableFuture<Void> stopAndSetStateTo(State stoppedState)
protected void onExceptionInOpen(RuntimeException e)
AbstractConfiguredObject
The method is not expected to throw any runtime exception.
onExceptionInOpen
in class AbstractConfiguredObject<X extends AbstractVirtualHostNode<X>>
e
- open exceptionprotected void postResolve()
postResolve
in class AbstractConfiguredObject<X extends AbstractVirtualHostNode<X>>
protected void onClose()
onClose
in class AbstractConfiguredObject<X extends AbstractVirtualHostNode<X>>
public String getVirtualHostInitialConfiguration()
getVirtualHostInitialConfiguration
in interface VirtualHostNode<X extends AbstractVirtualHostNode<X>>
public boolean isDefaultVirtualHostNode()
isDefaultVirtualHostNode
in interface VirtualHostNode<X extends AbstractVirtualHostNode<X>>
protected abstract DurableConfigurationStore createConfigurationStore()
protected abstract com.google.common.util.concurrent.ListenableFuture<Void> activate()
protected abstract ConfiguredObjectRecord enrichInitialVirtualHostRootRecord(ConfiguredObjectRecord vhostRecord)
protected final ConfiguredObjectRecord[] getInitialRecords() throws IOException
IOException
protected final Reader getInitialConfigReader() throws IOException
IOException
protected static Collection<String> getSupportedVirtualHostTypes(boolean includeProvided)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.