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

 
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, 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

RabbitBrokerImpl

public RabbitBrokerImpl()

 
Method Detail

connectSensors

super.connectSensors();
protected void connectSensors()

createQueue

public RabbitQueue createQueue(java.util.Map properties)

disconnectSensors

super.disconnectSensors();
public void disconnectSensors()

getAmqpPort

public java.lang.Integer getAmqpPort()

getAmqpVersion

public java.lang.String getAmqpVersion()

getDriver

@Override
public RabbitDriver getDriver()

getDriverInterface

return RabbitDriver.class;
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

return super.toStringHelper().add("amqpPort", getAmqpPort());
protected ToStringHelper toStringHelper()

 

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