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

brooklyn.entity.messaging.rabbit
[Groovy] Class RabbitBroker

java.lang.Object
  groovy.lang.GroovyObjectSupport
      brooklyn.entity.basic.AbstractEntity
          brooklyn.entity.basic.SoftwareProcessEntity
              brooklyn.entity.messaging.rabbit.RabbitBroker
All Implemented Interfaces:
AmqpServer, MessageBroker
class RabbitBroker
extends SoftwareProcessEntity

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

Field Summary
static PortAttributeSensorAndConfigKey AMQP_PORT

static BasicAttributeSensorAndConfigKey AMQP_VERSION

static BasicConfigKey ERLANG_VERSION

static BasicConfigKey SUGGESTED_VERSION

static BasicAttributeSensorAndConfigKey VIRTUAL_HOST_NAME

 
Fields inherited from class SoftwareProcessEntity
ADDRESS, CUSTOMIZE_LATCH, HOSTNAME, INSTALL_LATCH, LAUNCH_LATCH, PROVISIONING_PROPERTIES, SERVICE_STATE, SHELL_ENVIRONMENT, START_LATCH, SUGGESTED_INSTALL_DIR, SUGGESTED_RUN_DIR, SUGGESTED_VERSION, sensorRegistry
 
Fields inherited from class AbstractEntity
LOG, SENSOR_ADDED, SENSOR_REMOVED, _subscriptionTracker, application, attributesInternal, configsInternal, execution, managementContext, managementData, subscription, tempWorkings
 
Constructor Summary
RabbitBroker(java.util.Map properties = [:], Entity owner = null)

 
Method Summary
protected void connectSensors()

RabbitQueue createQueue(java.util.Map properties)

java.lang.Integer getAmqpPort()

java.lang.String getAmqpVersion()

java.lang.Class getDriverInterface()

java.lang.String getVirtualHost()

void postStart()

void setBrokerUrl()

java.util.Collection toStringFieldsToInclude()

 
Methods inherited from class SoftwareProcessEntity
checkAllSensorsConnected, checkModifiable, connectSensors, getDriver, getLocalHostname, getProvisioningFlags, getProvisioningLocation, getRequiredOpenPorts, initDriver, newDriver, obtainProvisioningFlags, postActivation, postStart, preStart, preStop, removeFirstMatchingLocation, removeFirstMatchingLocation, restart, setProvisioningLocation, start, startInLocation, startInLocation, startInLocation, stop, stopInLocation, waitForEntityStart, waitForServiceUp, waitForServiceUp
 
Methods inherited from class AbstractEntity
addEnricher, addGroup, addOwnedChild, addPolicy, assertNotYetOwned, clearOwner, configure, configure, destroy, emit, emitInternal, firstLocation, getAllConfig, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getConfig, getConfig, getConfig, getConfig, getConfigMap, getEffector, getEnrichers, getEntityType, getExecutionContext, getGroups, getLocations, getManagementContext, getMutableEntityType, getOwnedChildren, getOwner, getPolicies, getSubscriptionContext, getSubscriptionTracker, hasEverBeenManaged, invalidate, invoke, invoke, invokeFromJava, invokeMethod, onManagementBecomingMaster, onManagementNoLongerMaster, refreshInheritedConfig, refreshInheritedConfigOfChildren, removeAllEnrichers, removeAllPolicies, removeAttribute, removeEnricher, removeOwnedChild, removePolicy, setApplication, setAttribute, setAttribute, setBeingManaged, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setConfigIfValNonNull, setConfigIfValNonNull, setOwner, subscribe, subscribeToChildren, subscribeToMembers, toString, toStringFieldsToInclude, 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()
 

Field Detail

AMQP_PORT

@SetFromFlag("amqpPort")
public static final PortAttributeSensorAndConfigKey AMQP_PORT

AMQP_VERSION

@SetFromFlag("amqpVersion")
public static final BasicAttributeSensorAndConfigKey AMQP_VERSION

ERLANG_VERSION

@SetFromFlag("erlangVersion")
public static final BasicConfigKey ERLANG_VERSION

SUGGESTED_VERSION

@SetFromFlag("version")
public static final BasicConfigKey SUGGESTED_VERSION

VIRTUAL_HOST_NAME

@SetFromFlag("virtualHost")
public static final BasicAttributeSensorAndConfigKey VIRTUAL_HOST_NAME

 
Constructor Detail

RabbitBroker

RabbitBroker(java.util.Map properties = [:], Entity owner = null)

 
Method Detail

connectSensors

@Override
protected void connectSensors()

createQueue

RabbitQueue createQueue(java.util.Map properties)

getAmqpPort

java.lang.Integer getAmqpPort()

getAmqpVersion

java.lang.String getAmqpVersion()

getDriverInterface

@Override
java.lang.Class getDriverInterface()

getVirtualHost

java.lang.String getVirtualHost()

postStart

@Override
void postStart()

setBrokerUrl

void setBrokerUrl()

toStringFieldsToInclude

@Override
java.util.Collection toStringFieldsToInclude()

 

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