Overview  Package   Class  Deprecated  Index  Help 
Brooklyn
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

brooklyn.entity.messaging.rabbit
[Java] Class RabbitBrokerImpl

java.lang.Object
  groovy.lang.GroovyObjectSupport
      brooklyn.entity.basic.AbstractEntity
          brooklyn.entity.basic.SoftwareProcessImpl
              brooklyn.entity.messaging.rabbit.RabbitBrokerImpl
All Implemented Interfaces:
RabbitBroker
public class RabbitBrokerImpl
extends SoftwareProcessImpl

An Entity that represents a single Rabbit MQ broker instance, using AMQP 0-9-1.

Field Summary
 
Fields inherited from class SoftwareProcessImpl
sensorRegistry
 
Fields inherited from class AbstractEntity
LOG, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED, _subscriptionTracker, attributesInternal, configsInternal, managementSupport, tempWorkings
 
Constructor Summary
RabbitBrokerImpl()

RabbitBrokerImpl(java.util.Map properties)

RabbitBrokerImpl(Entity parent)

RabbitBrokerImpl(java.util.Map properties, Entity parent)

 
Method Summary
protected void connectSensors()

RabbitQueue createQueue(java.util.Map properties)

void disconnectSensors()

java.lang.Integer getAmqpPort()

java.lang.String getAmqpVersion()

RabbitDriver getDriver()

java.lang.Class getDriverInterface()

java.lang.String getRunDir()

java.util.Map getShellEnvironment()

java.lang.String getVirtualHost()

protected void postStart()

void setBrokerUrl()

protected ToStringHelper toStringHelper()

 
Methods inherited from class SoftwareProcessImpl
callRebindHooks, callStartHooks, checkModifiable, connectSensors, connectServiceUpIsRunning, disconnectSensors, disconnectServiceUpIsRunning, doInitDriver, getDriver, getLocalHostname, getMachineOrNull, getProvisioningFlags, getProvisioningLocation, getRequiredOpenPorts, newDriver, obtainProvisioningFlags, onManagementStarted, onManagementStarting, postDriverRestart, postDriverStart, postRebind, postRestart, postStart, preStart, preStop, rebind, restart, setProvisioningLocation, start, startInLocation, startInLocation, startInLocation, startInLocation, stop, stopInLocation, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp
 
Methods inherited from class AbstractEntity
addChild, addChild, addEnricher, addGroup, addLocations, addOwnedChild, addPolicy, assertNotYetOwned, clearOwner, clearParent, configure, configure, configure, configure, configure, createManagementSupport, destroy, emit, emitInternal, equals, finalize, firstLocation, getAllAttributes, getAllConfig, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getChildren, getChildrenReference, getConfig, getConfig, getConfig, getConfig, getConfigMap, getDisplayName, getEffector, getEnrichers, getEntityManager, getEntityType, getEntityTypeName, getExecutionContext, getGroups, getId, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getOwnedChildren, getOwnedChildrenReference, getOwner, getParent, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getSubscriptionTracker, hasEverBeenManaged, hashCode, init, invalidateReferences, invoke, invoke, invokeFromJava, invokeMethod, isLegacyConstruction, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStarted, onManagementStarting, refreshInheritedConfig, refreshInheritedConfigOfChildren, removeAllEnrichers, removeAllPolicies, removeAttribute, removeChild, removeEnricher, removeLocations, removeOwnedChild, removePolicy, setApplication, setAttribute, setAttribute, setAttributeWithoutPublishing, setBeingManaged, setConfig, setConfig, setConfig, setConfig, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setConfigIfValNonNull, setConfigIfValNonNull, setDisplayName, setManagementContext, setOwner, setParent, setProxy, subscribe, subscribeToChildren, subscribeToMembers, toString, toStringFieldsToInclude, toStringHelper, unsubscribe, unsubscribe
 
Methods inherited from class groovy.lang.GroovyObjectSupport
groovy.lang.GroovyObjectSupport#setProperty(java.lang.String, java.lang.Object), groovy.lang.GroovyObjectSupport#getProperty(java.lang.String), groovy.lang.GroovyObjectSupport#getMetaClass(), groovy.lang.GroovyObjectSupport#setMetaClass(groovy.lang.MetaClass), groovy.lang.GroovyObjectSupport#invokeMethod(java.lang.String, java.lang.Object), groovy.lang.GroovyObjectSupport#wait(), groovy.lang.GroovyObjectSupport#wait(long), groovy.lang.GroovyObjectSupport#wait(long, int), groovy.lang.GroovyObjectSupport#equals(java.lang.Object), groovy.lang.GroovyObjectSupport#toString(), groovy.lang.GroovyObjectSupport#hashCode(), groovy.lang.GroovyObjectSupport#getClass(), groovy.lang.GroovyObjectSupport#notify(), groovy.lang.GroovyObjectSupport#notifyAll()
 

Constructor Detail

RabbitBrokerImpl

public RabbitBrokerImpl()

RabbitBrokerImpl

public RabbitBrokerImpl(java.util.Map properties)

RabbitBrokerImpl

public RabbitBrokerImpl(Entity parent)

RabbitBrokerImpl

public RabbitBrokerImpl(java.util.Map properties, Entity parent)

 
Method Detail

connectSensors

@Override
protected void connectSensors()

createQueue

public RabbitQueue createQueue(java.util.Map properties)

disconnectSensors

@Override
public void disconnectSensors()

getAmqpPort

public java.lang.Integer getAmqpPort()

getAmqpVersion

public java.lang.String getAmqpVersion()

getDriver

@Override
public RabbitDriver getDriver()

getDriverInterface

@Override
public java.lang.Class getDriverInterface()

getRunDir

@Override
public java.lang.String getRunDir()

getShellEnvironment

@Override
public java.util.Map getShellEnvironment()

getVirtualHost

public java.lang.String getVirtualHost()

postStart

@Override
protected void postStart()

setBrokerUrl

public void setBrokerUrl()

toStringHelper

@Override
protected ToStringHelper toStringHelper()

 

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