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

brooklyn.entity.messaging.qpid
[Groovy] Class QpidBroker

java.lang.Object
  groovy.lang.GroovyObjectSupport
      brooklyn.entity.basic.AbstractEntity
          brooklyn.entity.basic.SoftwareProcessEntity
              brooklyn.entity.messaging.jms.JMSBroker
                  brooklyn.entity.messaging.qpid.QpidBroker
All Implemented Interfaces:
AmqpServer, UsesJmx
class QpidBroker
extends JMSBroker

An Entity that represents a single Qpid broker instance, using AMQP 0-10.

Field Summary
static PortAttributeSensorAndConfigKey AMQP_PORT

static BasicAttributeSensorAndConfigKey AMQP_VERSION

static java.lang.String CONFIG_XML

static java.lang.String PASSWD

static BasicConfigKey RUNTIME_FILES

Files to be copied to the server, map of "subpath/file.name": "classpath://foo/file.txt" (or other url)
static BasicConfigKey SUGGESTED_VERSION

static java.lang.String VIRTUALHOSTS_XML

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
 
Property Summary
JmxSensorAdapter jmxAdapter

 
Constructor Summary
QpidBroker(java.util.Map properties = [:], Entity owner = null)

 
Method Summary
protected void connectSensors()

QpidQueue createQueue(java.util.Map properties)

QpidTopic createTopic(java.util.Map properties)

java.lang.Integer getAmqpPort()

java.lang.String getAmqpVersion()

java.lang.Class getDriverInterface()

protected java.util.Collection getRequiredOpenPorts()

java.lang.String getVirtualHost()

not configurable; must be 100 more than JMX port
protected void preStart()

void setBrokerUrl()

java.util.Collection toStringFieldsToInclude()

 
Methods inherited from class JMSBroker
addQueue, addTopic, configure, createQueue, createTopic, postStart, preStop, setBrokerUrl
 
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

CONFIG_XML

public static final java.lang.String CONFIG_XML

PASSWD

public static final java.lang.String PASSWD

RUNTIME_FILES

@SetFromFlag("runtimeFiles")
public static final BasicConfigKey RUNTIME_FILES
Files to be copied to the server, map of "subpath/file.name": "classpath://foo/file.txt" (or other url)

SUGGESTED_VERSION

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

VIRTUALHOSTS_XML

public static final java.lang.String VIRTUALHOSTS_XML

VIRTUAL_HOST_NAME

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

 
Property Detail

jmxAdapter

JmxSensorAdapter jmxAdapter

 
Constructor Detail

QpidBroker

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

 
Method Detail

connectSensors

@Override
protected void connectSensors()

createQueue

QpidQueue createQueue(java.util.Map properties)

createTopic

QpidTopic createTopic(java.util.Map properties)

getAmqpPort

java.lang.Integer getAmqpPort()

getAmqpVersion

java.lang.String getAmqpVersion()

getDriverInterface

java.lang.Class getDriverInterface()

getRequiredOpenPorts

@Override
protected java.util.Collection getRequiredOpenPorts()

getVirtualHost

java.lang.String getVirtualHost()
not configurable; must be 100 more than JMX port

preStart

@Override
protected void preStart()

setBrokerUrl

void setBrokerUrl()

toStringFieldsToInclude

@Override
java.util.Collection toStringFieldsToInclude()

 

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