org.apache.qpid.server.virtualhostnode.berkeleydb

Class BDBHARemoteReplicationNodeImpl

java.lang.Object

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

org.apache.qpid.server.virtualhostnode.berkeleydb.BDBHARemoteReplicationNodeImpl

All Implemented Interfaces:

ConfiguredObject<BDBHARemoteReplicationNodeImpl>, ContextProvider, PermissionedObject, RemoteReplicationNode<BDBHARemoteReplicationNodeImpl>, TaskExecutorProvider, BDBHARemoteReplicationNode<BDBHARemoteReplicationNodeImpl>

public class BDBHARemoteReplicationNodeImpl
extends AbstractConfiguredObject<BDBHARemoteReplicationNodeImpl>
implements BDBHARemoteReplicationNode<BDBHARemoteReplicationNodeImpl>

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 inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

SECURED_STRING_VALUE

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

ADDRESS, GROUP_NAME, JOIN_TIME, LAST_KNOWN_REPLICATION_TRANSACTION_ID, MONITOR, ROLE

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
BDBHARemoteReplicationNodeImpl(BDBHAVirtualHostNode<?> virtualHostNode, Map<String,Object> attributes, ReplicatedEnvironmentFacade replicatedEnvironmentFacade)

Method Summary

Modifier and Type	Method and Description
protected void	afterSetRole()
protected com.google.common.util.concurrent.ListenableFuture<Void>	deleteNoChecks()
String	getAddress()
String	getGroupName()
Date	getJoinTime()
long	getLastKnownReplicationTransactionId()
NodeRole	getRole()
boolean	isMonitor()
protected com.google.common.util.concurrent.ListenableFuture<Void>	onDelete()
void	onValidate()
String	toString()
protected void	validateChange(ConfiguredObject<?> proxyForValidation, Set<String> changedAttributes)

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

addChangeListener, addChildAsync, addFutureCallback, applyToChildren, asObjectRecord, attainState, attributeSet, authorise, authorise, authorise, authoriseCreateChild, awaitChildClassToAttainState, awaitChildClassToAttainState, beforeClose, beforeDelete, changeAttributes, childAdded, childRemoved, close, closeAsync, closeChildren, create, createAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, deleteChildren, 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, getChildExecutor, getChildren, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getLifetimePolicy, 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, onClose, onCreate, onExceptionInOpen, onOpen, onResolve, open, openAsync, postResolve, postResolveChildren, postSetAttributes, registerWithParents, removeChangeListener, removeContextVariable, rethrowRuntimeExceptionsOnOpen, runTask, setAttributes, setAttributesAsync, setContextVariable, setEncrypter, setState, setUserPreferences, start, startAsync, stop, updateModel, validateChildDelete, validateOnCreate

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.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, getName, 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

Constructor Detail

BDBHARemoteReplicationNodeImpl

public BDBHARemoteReplicationNodeImpl(BDBHAVirtualHostNode<?> virtualHostNode,
                                      Map<String,Object> attributes,
                                      ReplicatedEnvironmentFacade replicatedEnvironmentFacade)

Method Detail

getGroupName

public String getGroupName()

Specified by:

getGroupName in interface BDBHARemoteReplicationNode<BDBHARemoteReplicationNodeImpl>

getAddress

public String getAddress()

Specified by:

getAddress in interface BDBHARemoteReplicationNode<BDBHARemoteReplicationNodeImpl>

getRole

public NodeRole getRole()

Specified by:

getRole in interface BDBHARemoteReplicationNode<BDBHARemoteReplicationNodeImpl>

getJoinTime

public Date getJoinTime()

Specified by:

getJoinTime in interface BDBHARemoteReplicationNode<BDBHARemoteReplicationNodeImpl>

getLastKnownReplicationTransactionId

public long getLastKnownReplicationTransactionId()

Specified by:

getLastKnownReplicationTransactionId in interface BDBHARemoteReplicationNode<BDBHARemoteReplicationNodeImpl>

isMonitor

public boolean isMonitor()

Specified by:

isMonitor in interface BDBHARemoteReplicationNode<BDBHARemoteReplicationNodeImpl>

toString

public String toString()

Overrides:

toString in class AbstractConfiguredObject<BDBHARemoteReplicationNodeImpl>

onDelete

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

Overrides:

onDelete in class AbstractConfiguredObject<BDBHARemoteReplicationNodeImpl>

afterSetRole

protected void afterSetRole()

validateChange

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

Overrides:

validateChange in class AbstractConfiguredObject<BDBHARemoteReplicationNodeImpl>

onValidate

public void onValidate()

Overrides:

onValidate in class AbstractConfiguredObject<BDBHARemoteReplicationNodeImpl>

deleteNoChecks

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

Overrides:

deleteNoChecks in class AbstractConfiguredObject<BDBHARemoteReplicationNodeImpl>