brooklyn.management.internal
[Java] Class AbstractManagementContext

java.lang.Object
  brooklyn.management.internal.AbstractManagementContext

All Implemented Interfaces:

ManagementContextInternal

public abstract class AbstractManagementContext

baseClassLoader

protected java.lang.ClassLoader baseClassLoader

baseClassPathForScanning

protected java.lang.Iterable baseClassPathForScanning

catalog

protected BasicBrooklynCatalog catalog

configMap

protected BrooklynProperties configMap

downloadsManager

protected DownloadResolverManager downloadsManager

gc

protected BrooklynGarbageCollector gc

locationRegistry

protected BasicLocationRegistry locationRegistry

AbstractManagementContext

public AbstractManagementContext(BrooklynProperties brooklynProperties)

AbstractManagementContext

public AbstractManagementContext(BrooklynProperties brooklynProperties, DataGridFactory datagridFactory)

addEntitySetListener

@java.lang.Override
public void addEntitySetListener(CollectionChangeListener listener)

getBaseClassLoader

@java.lang.Override
public java.lang.ClassLoader getBaseClassLoader()

Optional class-loader that this management context should use as its base, as the first-resort in the catalog, and for scanning (if scanning the default in the catalog). In most instances the default classloader (ManagementContext.class.getClassLoader(), assuming this was in the JARs used at boot time) is fine, and in those cases this method normally returns null. (Surefire does some weird stuff, but the default classloader is fine for loading; however it requires a custom base classpath to be set for scanning.)

getBaseClassPathForScanning

@java.lang.Override
public java.lang.Iterable getBaseClassPathForScanning()

getBrooklynProperties

@java.lang.Override
public BrooklynProperties getBrooklynProperties()

getCatalog

@java.lang.Override
public BrooklynCatalog getCatalog()

getConfig

@java.lang.Overridepublic synchronized LocationRegistry getLocationRegistry() {
public StringConfigMap getConfig()

getEntityDownloadsManager

@java.lang.Overridereturn runAtEntity(entity, eff, parameters);
public DownloadResolverManager getEntityDownloadsManager()

getEntityDriverManager

@java.lang.Override
public EntityDriverManager getEntityDriverManager()

getExecutionContext

@java.lang.Overridepublic SubscriptionContext getSubscriptionContext(Entity e) {
public ExecutionContext getExecutionContext(Entity e)

getLocationRegistry

@java.lang.Override
public LocationRegistry getLocationRegistry()

getRebindManager

@java.lang.Overridereturn totalEffectorInvocationCount.get();
public RebindManager getRebindManager()

getStorage

@java.lang.Overridereturn rebindManager;
public BrooklynStorage getStorage()

getSubscriptionContext

@java.lang.Overridereturn entityDriverManager;
public SubscriptionContext getSubscriptionContext(Entity e)

getTotalEffectorInvocations

@java.lang.Override// BEC is a thin wrapper around EM so fine to create a new one here
public long getTotalEffectorInvocations()

invokeEffector

@java.lang.Overridereturn GroovyJavaMethods.invokeMethodOnMetaClass(entity, eff.getName(), transformedArgs);
public Task invokeEffector(Entity entity, Effector eff, @java.lang.SuppressWarnings java.util.Map parameters)

invokeEffectorMethodLocal

protected java.lang.Object invokeEffectorMethodLocal(Entity entity, Effector eff, java.lang.Object args)

invokeEffectorMethodSync

@java.lang.Overridenew Callable() {
public java.lang.Object invokeEffectorMethodSync(Entity entity, Effector eff, java.lang.Object args)

isManagedLocally

public boolean isManagedLocally(Entity e)

Whether the master entity record is local, and sensors and effectors can be properly accessed locally.

isRunning

@java.lang.Overridereturn storage;
public boolean isRunning()

loadCatalog

protected void loadCatalog()

manageIfNecessary

protected void manageIfNecessary(Entity entity, java.lang.Object context)

removeEntitySetListener

@java.lang.Override}
public void removeEntitySetListener(CollectionChangeListener listener)

runAtEntity

@java.lang.Deprecated@Override
public Task runAtEntity(@java.lang.SuppressWarnings java.util.Map flags, Entity entity, java.util.concurrent.Callable c)

runAtEntity

protected Task runAtEntity(Entity entity, Effector eff, @java.lang.SuppressWarnings java.util.Map parameters)

setBaseClassLoader

public void setBaseClassLoader(java.lang.ClassLoader cl)

setBaseClassPathForScanning

@java.lang.Overridereturn baseClassPathForScanning;
public void setBaseClassPathForScanning(java.lang.Iterable urls)

See Also:

setBaseClassPathForScanning(Iterable)

terminate

@java.lang.Overridestorage.terminate();
public void terminate()

Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.