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
  brooklyn.entity.basic.AbstractEntity
      brooklyn.entity.basic.SoftwareProcessImpl
          brooklyn.entity.messaging.jms.JMSBrokerImpl
              brooklyn.entity.messaging.qpid.QpidBrokerImpl
All Implemented Interfaces:
QpidBroker
public class QpidBrokerImpl
extends JMSBrokerImpl

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

Field Summary
 
Fields inherited from class SoftwareProcessImpl
connectedSensors
 
Fields inherited from class AbstractEntity
EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, LOG, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED, _subscriptionTracker, managementSupport, tempWorkings
 
Constructor Summary
QpidBrokerImpl()

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

void setBrokerUrl()

protected ToStringHelper toStringHelper()

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

 
Methods inherited from class JMSBrokerImpl
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, doRestart, doStart, doStop, getDriver, getLocalHostname, getMachineOrNull, getProvisioningFlags, getProvisioningLocation, getRequiredOpenPorts, newDriver, obtainProvisioningFlags, onManagementStarted, onManagementStarting, postDriverStart, postRebind, postStart, preStart, preStop, rebind, restart, setProvisioningLocation, start, startInLocation, startInLocation, startInLocation, startInLocation, stop, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp, waitForServiceUp
 
Methods inherited from class AbstractEntity
addChild, addChild, addEnricher, addGroup, addLocations, addPolicy, clearLocations, clearParent, configure, configure, configure, configure, configure, configure, destroy, emit, emitInternal, equals, finalize, firstLocation, getAllAttributes, getAllConfig, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getChildren, getConfig, getConfig, getConfig, getConfig, getConfigMap, getCreationTime, getDisplayName, getEffector, getEnrichers, getEntityManager, getEntityType, getEntityTypeName, getExecutionContext, getGroups, getIconUrl, getId, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getParent, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getSubscriptionTracker, hashCode, init, invalidateReferences, invoke, invoke, invoke, isLegacyConstruction, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStarted, onManagementStarting, onManagementStopped, refreshInheritedConfig, removeAllEnrichers, removeAllPolicies, removeAttribute, removeChild, removeEnricher, removeLocations, removePolicy, setApplication, setAttribute, setAttribute, setAttributeWithoutPublishing, setConfig, setConfig, setConfig, setConfig, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setConfigIfValNonNull, setConfigIfValNonNull, setDisplayName, setManagementContext, setParent, setProxy, subscribe, subscribeToChildren, subscribeToMembers, toMetadataRecord, toString, toStringHelper, unsubscribe, unsubscribe
 

Constructor Detail

QpidBrokerImpl

public QpidBrokerImpl()

 
Method Detail

connectSensors

protected void connectSensors() {
protected void connectSensors()

createQueue

public QpidQueue createQueue(java.util.Map properties)

createTopic

public QpidTopic createTopic(java.util.Map properties)

disconnectSensors

public void disconnectSensors() {
public void disconnectSensors()

getAmqpPort

public java.lang.Integer getAmqpPort()

getAmqpVersion

public java.lang.String getAmqpVersion()

getDriverInterface

public Class getDriverInterface() {
public java.lang.Class getDriverInterface()

getVirtualHost

public java.lang.String getVirtualHost()

init

@Override
public void init()

setBrokerUrl

public void setBrokerUrl()

toStringHelper

protected ToStringHelper toStringHelper() {
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.