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

brooklyn.entity.messaging.qpid
[Java] Class QpidBrokerImpl

java.lang.Object
  groovy.lang.GroovyObjectSupport
      brooklyn.entity.basic.AbstractEntity
          brooklyn.entity.basic.SoftwareProcessImpl
              brooklyn.entity.messaging.jms.JMSBroker
                  brooklyn.entity.messaging.qpid.QpidBrokerImpl
All Implemented Interfaces:
QpidBroker
public class QpidBrokerImpl
extends JMSBroker

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

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
QpidBrokerImpl()

QpidBrokerImpl(java.util.Map properties)

QpidBrokerImpl(Entity parent)

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

 
Method Summary
protected void connectSensors()

QpidQueue createQueue(java.util.Map properties)

QpidTopic createTopic(java.util.Map properties)

void disconnectSensors()

java.lang.Integer getAmqpPort()

java.lang.String getAmqpVersion()

java.lang.Class getDriverInterface()

java.lang.String getVirtualHost()

void setBrokerUrl()

protected ToStringHelper toStringHelper()

void waitForServiceUp(long duration, java.util.concurrent.TimeUnit units)

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

QpidBrokerImpl

public QpidBrokerImpl()

QpidBrokerImpl

public QpidBrokerImpl(java.util.Map properties)

QpidBrokerImpl

public QpidBrokerImpl(Entity parent)

QpidBrokerImpl

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

 
Method Detail

connectSensors

@Override
protected void connectSensors()

createQueue

public QpidQueue createQueue(java.util.Map properties)

createTopic

public QpidTopic createTopic(java.util.Map properties)

disconnectSensors

@Override
public void disconnectSensors()

getAmqpPort

public java.lang.Integer getAmqpPort()

getAmqpVersion

public java.lang.String getAmqpVersion()

getDriverInterface

@Override
public java.lang.Class getDriverInterface()

getVirtualHost

public java.lang.String getVirtualHost()

setBrokerUrl

public void setBrokerUrl()

toStringHelper

@Override
protected ToStringHelper toStringHelper()

waitForServiceUp

public void waitForServiceUp(long duration, java.util.concurrent.TimeUnit units)

 

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