RabbitBrokerImpl (Apache Brooklyn)

java.lang.Object
- brooklyn.basic.AbstractBrooklynObject
- - brooklyn.entity.basic.AbstractEntity
  - - brooklyn.entity.basic.SoftwareProcessImpl
    - - brooklyn.entity.messaging.rabbit.RabbitBrokerImpl

All Implemented Interfaces:

BrooklynObject, BrooklynObjectInternal, EntityInternal, EntityLocal, SoftwareProcess, DriverDependentEntity, Entity, AmqpServer, MessageBroker, RabbitBroker, Rebindable, Configurable, Identifiable, Startable
```
public class RabbitBrokerImpl
extends SoftwareProcessImpl
implements RabbitBroker
```
An Entity that represents a single Rabbit MQ broker instance, using AMQP 0-9-1.

Nested Class Summary
- Nested classes/interfaces inherited from interface brooklyn.entity.basic.SoftwareProcess
  SoftwareProcess.ChildStartableMode, SoftwareProcess.RestartSoftwareParameters
- Nested classes/interfaces inherited from interface brooklyn.entity.trait.Startable
  Startable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBody
- Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObject
  BrooklynObject.TagSupport
- Nested classes/interfaces inherited from interface brooklyn.entity.basic.EntityInternal
  EntityInternal.FeedSupport

Field Summary
- Fields inherited from class brooklyn.entity.basic.AbstractEntity
  CHILD_ADDED, CHILD_REMOVED, EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED
- Fields inherited from interface brooklyn.entity.messaging.rabbit.RabbitBroker
  AMQP_PORT, AMQP_VERSION, DOWNLOAD_URL, ERLANG_VERSION, SUGGESTED_VERSION, VIRTUAL_HOST_NAME
- Fields inherited from interface brooklyn.entity.basic.SoftwareProcess
  ADDRESS, CHILDREN_STARTABLE_MODE, CUSTOMIZE_LATCH, DOWNLOAD_ADDON_URLS, ENTITY_STARTED, EXPANDED_INSTALL_DIR, HOSTNAME, INSTALL_DIR, INSTALL_FILES, INSTALL_LATCH, INSTALL_RESOURCES_LATCH, INSTALL_TEMPLATES, INSTALL_UNIQUE_LABEL, LAUNCH_LATCH, MAXIMUM_REBIND_SENSOR_CONNECT_DELAY, PID_FILE, POST_INSTALL_COMMAND, POST_LAUNCH_COMMAND, PRE_INSTALL_COMMAND, PRE_LAUNCH_COMMAND, PROVISIONING_LOCATION, PROVISIONING_PROPERTIES, RUN_DIR, RUNTIME_FILES, RUNTIME_RESOURCES_LATCH, RUNTIME_TEMPLATES, SERVICE_PROCESS_IS_RUNNING, SERVICE_STATE_ACTUAL, SETUP_LATCH, SHELL_ENVIRONMENT, SKIP_INSTALLATION, START_LATCH, START_TIMEOUT, SUBNET_ADDRESS, SUBNET_HOSTNAME, SUGGESTED_INSTALL_DIR, SUGGESTED_RUN_DIR
- Fields inherited from interface brooklyn.entity.trait.Startable
  RESTART, SERVICE_UP, START, STOP
- Fields inherited from interface brooklyn.entity.messaging.MessageBroker
  BROKER_URL
- Fields inherited from interface brooklyn.entity.messaging.amqp.AmqpServer
  AMQP_0_10, AMQP_0_8, AMQP_0_9, AMQP_0_9_1, AMQP_1_0

Constructor Summary

Constructors
Constructor and Description

RabbitBrokerImpl()

Constructors
Constructor and Description
`RabbitBrokerImpl()`

Method Summary

Methods
Modifier and Type	Method and Description
`RabbitQueue`	`createQueue(java.util.Map properties)`
`void`	`disconnectSensors()` For disconnecting from the running app.
`java.lang.Integer`	`getAmqpPort()`
`java.lang.String`	`getAmqpVersion()`
`RabbitDriver`	`getDriver()`
`java.lang.Class<? extends RabbitDriver>`	`getDriverInterface()`
`java.lang.String`	`getRunDir()`
`java.util.Map<java.lang.String,java.lang.String>`	`getShellEnvironment()`
`java.lang.String`	`getVirtualHost()`
`void`	`setBrokerUrl()` Setup the URL for external connections to the broker.

Methods inherited from class brooklyn.entity.basic.SoftwareProcessImpl
checkModifiable, getLocalHostname, init, onManagementStarted, onManagementStarting, rebind, restart, start, stop, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp, waitForServiceUp

Methods inherited from class brooklyn.entity.basic.AbstractEntity
addChild, addChild, addEnricher, addEnricher, addFeed, addGroup, addLocations, addPolicy, addPolicy, addTag, clearLocations, clearParent, configure, configure, configure, configure, configure, containsTag, destroy, emit, emitInternal, equals, feeds, firstLocation, getAllAttributes, getAllConfig, getAllConfigBag, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getChildren, getConfig, getConfig, getConfig, getConfig, getConfigMap, getConfigRaw, getConfigRaw, getCreationTime, getDisplayName, getEffector, getEnrichers, getEntityType, getExecutionContext, getFeedSupport, getGroups, getIconUrl, getLocalConfigBag, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getParent, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getTags, hashCode, invalidateReferences, invoke, invoke, invoke, modifyAttribute, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStopped, refreshInheritedConfig, removeAllEnrichers, removeAllPolicies, removeAttribute, removeChild, removeEnricher, removeGroup, removeLocations, removePolicy, removeTag, requestPersist, resetProxy, setAttribute, setAttribute, setAttributeWithoutPublishing, setConfig, setConfig, setConfig, setConfig, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setDisplayName, setManagementContext, setParent, setProxy, subscribe, subscribeToChildren, subscribeToMembers, toMetadataRecord, toString, unsubscribe, unsubscribe

Methods inherited from class brooklyn.basic.AbstractBrooklynObject
getCatalogItemId, getId, getTagSupport, setCatalogItemId, tags

Methods inherited from class java.lang.Object
getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface brooklyn.entity.trait.Startable
restart, start, stop

Methods inherited from interface brooklyn.entity.Entity
addChild, addChild, addEnricher, addEnricher, addFeed, addGroup, addPolicy, addPolicy, addTag, clearParent, containsTag, getApplication, getApplicationId, getAttribute, getChildren, getConfig, getConfig, getConfigRaw, getConfigRaw, getCreationTime, getDisplayName, getEnrichers, getEntityType, getGroups, getIconUrl, getId, getLocations, getParent, getPolicies, getTags, invoke, removeChild, removeEnricher, removeGroup, removePolicy, removeTag, setParent

Methods inherited from interface brooklyn.basic.BrooklynObject
getCatalogItemId, getTagSupport, tags

Methods inherited from interface brooklyn.basic.BrooklynObjectInternal
setCatalogItemId

- Constructor Detail
  - RabbitBrokerImpl
```
public RabbitBrokerImpl()
```
- Method Detail
  - getVirtualHost
```
public java.lang.String getVirtualHost()
```
    Specified by:
    
    getVirtualHost in interface AmqpServer
  - getAmqpVersion
```
public java.lang.String getAmqpVersion()
```
    Specified by:
    
    getAmqpVersion in interface AmqpServer
  - getAmqpPort
```
public java.lang.Integer getAmqpPort()
```
    Specified by:
    
    getAmqpPort in interface AmqpServer
  - getDriver
```
public RabbitDriver getDriver()
```
    Specified by:
    
    getDriver in interface DriverDependentEntity
    
    Overrides:
    
    getDriver in class SoftwareProcessImpl
  - getShellEnvironment
```
public java.util.Map<java.lang.String,java.lang.String> getShellEnvironment()
```
    Specified by:
    
    getShellEnvironment in interface RabbitBroker
  - getRunDir
```
public java.lang.String getRunDir()
```
    Specified by:
    
    getRunDir in interface RabbitBroker
  - setBrokerUrl
```
public void setBrokerUrl()
```
    Description copied from interface: MessageBroker
    
    Setup the URL for external connections to the broker.
    
    Specified by:
    
    setBrokerUrl in interface MessageBroker
  - createQueue
```
public RabbitQueue createQueue(java.util.Map properties)
```
    Specified by:
    
    createQueue in interface RabbitBroker
  - getDriverInterface
```
public java.lang.Class<? extends RabbitDriver> getDriverInterface()
```
    Specified by:
    
    getDriverInterface in interface DriverDependentEntity
  - disconnectSensors
```
public void disconnectSensors()
```
    Description copied from class: SoftwareProcessImpl
    
    For disconnecting from the running app. Will be called on stop.

Class RabbitBrokerImpl

Nested Class Summary

Nested classes/interfaces inherited from interface brooklyn.entity.basic.SoftwareProcess

Nested classes/interfaces inherited from interface brooklyn.entity.trait.Startable

Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObject

Nested classes/interfaces inherited from interface brooklyn.entity.basic.EntityInternal

Field Summary

Fields inherited from class brooklyn.entity.basic.AbstractEntity

Fields inherited from interface brooklyn.entity.messaging.rabbit.RabbitBroker

Fields inherited from interface brooklyn.entity.basic.SoftwareProcess

Fields inherited from interface brooklyn.entity.trait.Startable

Fields inherited from interface brooklyn.entity.messaging.MessageBroker

Fields inherited from interface brooklyn.entity.messaging.amqp.AmqpServer

Constructor Summary

Method Summary

Methods inherited from class brooklyn.entity.basic.SoftwareProcessImpl

Methods inherited from class brooklyn.entity.basic.AbstractEntity

Methods inherited from class brooklyn.basic.AbstractBrooklynObject

Methods inherited from class java.lang.Object

Methods inherited from interface brooklyn.entity.trait.Startable

Methods inherited from interface brooklyn.entity.Entity

Methods inherited from interface brooklyn.basic.BrooklynObject

Methods inherited from interface brooklyn.basic.BrooklynObjectInternal

Constructor Detail

RabbitBrokerImpl

Method Detail

getVirtualHost

getAmqpVersion

getAmqpPort

getDriver

getShellEnvironment

getRunDir

setBrokerUrl

createQueue

getDriverInterface

disconnectSensors