org.apache.brooklyn.entity.messaging.jms

Class JMSBrokerImpl<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>

java.lang.Object

org.apache.brooklyn.core.objs.AbstractBrooklynObject

org.apache.brooklyn.core.entity.AbstractEntity

org.apache.brooklyn.entity.software.base.SoftwareProcessImpl

org.apache.brooklyn.entity.messaging.jms.JMSBrokerImpl<Q,T>

All Implemented Interfaces:

DriverDependentEntity, Entity, EntityLocal, Rebindable, BrooklynObject, Configurable, Identifiable, EntityInternal, Startable, BrooklynObjectInternal, JMSBroker<Q,T>, MessageBroker, SoftwareProcess

Direct Known Subclasses:

ActiveMQBrokerImpl, QpidBrokerImpl

public abstract class JMSBrokerImpl<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>
extends SoftwareProcessImpl
implements JMSBroker<Q,T>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.brooklyn.entity.software.base.SoftwareProcessImpl

SoftwareProcessImpl.ServiceNotUpDiagnosticsCollector, SoftwareProcessImpl.UpdatingNotUpFromServiceProcessIsRunning

Nested classes/interfaces inherited from class org.apache.brooklyn.core.entity.AbstractEntity

AbstractEntity.BasicConfigurationSupport, AbstractEntity.BasicEnricherSupport, AbstractEntity.BasicGroupSupport, AbstractEntity.BasicPolicySupport, AbstractEntity.BasicSensorSupport, AbstractEntity.BasicSubscriptionSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.entity.software.base.SoftwareProcess

SoftwareProcess.ChildStartableMode, SoftwareProcess.RestartSoftwareParameters, SoftwareProcess.StopSoftwareParameters

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

Startable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBody

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.entity.Entity

Entity.AdjunctSupport<T extends EntityAdjunct>, Entity.EnricherSupport, Entity.GroupSupport, Entity.PolicySupport, Entity.SensorSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.objs.BrooklynObject

BrooklynObject.RelationSupport<T extends BrooklynObject>, BrooklynObject.SubscriptionSupport, BrooklynObject.TagSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.objs.Configurable

Configurable.ConfigurationSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.core.entity.EntityInternal

EntityInternal.EnricherSupportInternal, EntityInternal.EntitySubscriptionSupportInternal, EntityInternal.FeedSupport, EntityInternal.GroupSupportInternal, EntityInternal.PolicySupportInternal, EntityInternal.SensorSupportInternal

Nested classes/interfaces inherited from interface org.apache.brooklyn.core.objs.BrooklynObjectInternal

BrooklynObjectInternal.ConfigurationSupportInternal, BrooklynObjectInternal.RelationSupportInternal<T extends BrooklynObject>, BrooklynObjectInternal.SubscriptionSupportInternal

Field Summary

Fields inherited from class org.apache.brooklyn.core.entity.AbstractEntity

APPLICATION_ID, CATALOG_ID, CHILD_ADDED, CHILD_REMOVED, CONFIG_KEY_ADDED, CONFIG_KEY_REMOVED, DEFAULT_DISPLAY_NAME, EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, ENTITY_ID, GROUP_ADDED, GROUP_REMOVED, LOCATION_ADDED, LOCATION_REMOVED, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED

Fields inherited from interface org.apache.brooklyn.entity.software.base.SoftwareProcess

ADD_OPEN_INBOUND_PORTS_EFFECTOR, ADDRESS, ARCHIVE_DIRECTORY_NAME_FORMAT, CHILDREN_STARTABLE_MODE, CUSTOMIZE_FILES, CUSTOMIZE_LATCH, CUSTOMIZE_TEMPLATES, DONT_REQUIRE_TTY_FOR_SUDO, DOWNLOAD_ADDON_URLS, DOWNLOAD_URL, ENTITY_STARTED, EXPANDED_INSTALL_DIR, HOSTNAME, INBOUND_PORTS_AUTO_INFER, INBOUND_PORTS_CONFIG_REGEX, INSTALL_DIR, INSTALL_FILES, INSTALL_LATCH, INSTALL_RESOURCES_LATCH, INSTALL_TEMPLATES, INSTALL_UNIQUE_LABEL, LAUNCH_LATCH, LIFECYCLE_EFFECTOR_TASKS, MAXIMUM_REBIND_SENSOR_CONNECT_DELAY, OPEN_IPTABLES, PID_FILE, POST_CUSTOMIZE_COMMAND, POST_INSTALL_COMMAND, POST_LAUNCH_COMMAND, PRE_CUSTOMIZE_COMMAND, PRE_INSTALL_COMMAND, PRE_INSTALL_FILES, PRE_INSTALL_TEMPLATES, PRE_LAUNCH_COMMAND, PROVISIONING_LOCATION, PROVISIONING_PROPERTIES, REQUIRED_OPEN_LOGIN_PORTS, RETRIEVE_USAGE_METRICS, RUN_DIR, RUNTIME_FILES, RUNTIME_RESOURCES_LATCH, RUNTIME_TEMPLATES, SERVICE_PROCESS_IS_RUNNING, SERVICE_PROCESS_IS_RUNNING_POLL_PERIOD, SERVICE_STATE_ACTUAL, SERVICE_STATE_EXPECTED, SETUP_LATCH, SHELL_ENVIRONMENT, SKIP_ENTITY_START_IF_RUNNING, SKIP_INSTALLATION, START_LATCH, START_TIMEOUT, STOP_IPTABLES, STOP_LATCH, SUBNET_ADDRESS, SUBNET_HOSTNAME, SUGGESTED_VERSION, TEMPLATE_SUBSTITUTIONS

Fields inherited from interface org.apache.brooklyn.core.entity.trait.Startable

RESTART, SERVICE_UP, START, STOP

Fields inherited from interface org.apache.brooklyn.entity.messaging.MessageBroker

BROKER_URL

Constructor Summary

Constructors

Constructor and Description
JMSBrokerImpl()

Method Summary

Modifier and Type	Method and Description
void	addQueue(java.lang.String name) TODO make this an effector
void	addQueue(java.lang.String name, java.util.Map properties)
void	addTopic(java.lang.String name) TODO make this an effector
void	addTopic(java.lang.String name, java.util.Map properties)
void	checkStartingOrRunning()
JMSBrokerImpl	configure(java.util.Map properties) Will set fields from flags, and put the remaining ones into the 'leftovers' map.
abstract Q	createQueue(java.util.Map properties)
abstract T	createTopic(java.util.Map properties)
java.util.Collection<java.lang.String>	getQueueNames()
java.util.Map<java.lang.String,Q>	getQueues()
java.util.Collection<java.lang.String>	getTopicNames()
java.util.Map<java.lang.String,T>	getTopics()
void	preStop()
abstract void	setBrokerUrl() Setup the URL for external connections to the broker.

Methods inherited from class org.apache.brooklyn.entity.software.base.SoftwareProcessImpl

getDriver, init, onManagementStarted, onManagementStarting, populateServiceNotUpDiagnostics, rebind, restart, start, stop, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp, waitForServiceUp

Methods inherited from class org.apache.brooklyn.core.entity.AbstractEntity

addChild, addChild, addFeed, addLocations, addLocationsWithoutPublishing, clearLocations, clearParent, config, configure, destroy, enrichers, equals, feeds, firstLocation, getApplication, getApplicationId, getAttribute, getChildren, getConfig, getConfig, getCreationTime, getDisplayName, getEffector, getEntityType, getExecutionContext, getIconUrl, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getParent, getProxy, getProxyIfAvailable, getRebindSupport, groups, hashCode, invalidateReferences, invoke, invoke, invoke, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStopped, policies, relations, removeChild, removeLocations, requestPersist, resetProxy, sensors, setConfigEvenIfOwned, setConfigEvenIfOwned, setDisplayName, setManagementContext, setParent, setProxy, subscriptions, toMetadataRecord, toString

Methods inherited from class org.apache.brooklyn.core.objs.AbstractBrooklynObject

addSearchPath, getCatalogItemId, getCatalogItemIdSearchPath, getId, setCatalogItemId, setCatalogItemIdAndSearchPath, stackCatalogItemId, tags

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.brooklyn.entity.software.base.SoftwareProcess

populateServiceNotUpDiagnostics

Methods inherited from interface org.apache.brooklyn.core.entity.trait.Startable

restart, start, stop

Methods inherited from interface org.apache.brooklyn.api.entity.Entity

addChild, addChild, addFeed, clearParent, enrichers, getApplication, getApplicationId, getAttribute, getChildren, getConfig, getCreationTime, getDisplayName, getEntityType, getIconUrl, getId, getLocations, getParent, groups, invoke, policies, relations, removeChild, sensors, setDisplayName, setParent

Methods inherited from interface org.apache.brooklyn.api.objs.BrooklynObject

getCatalogItemId, getCatalogItemIdSearchPath, subscriptions, tags

Methods inherited from interface org.apache.brooklyn.api.objs.Configurable

config, getConfig

Methods inherited from interface org.apache.brooklyn.api.entity.drivers.DriverDependentEntity

getDriverInterface

Methods inherited from interface org.apache.brooklyn.core.objs.BrooklynObjectInternal

addSearchPath, setCatalogItemId, setCatalogItemIdAndSearchPath, stackCatalogItemId

Constructor Detail

JMSBrokerImpl

public JMSBrokerImpl()

Method Detail

configure

public JMSBrokerImpl configure(java.util.Map properties)

Description copied from class: AbstractBrooklynObject

Will set fields from flags, and put the remaining ones into the 'leftovers' map. For some types, you can find unused config via ConfigBag.getUnusedConfig().

To be overridden by AbstractEntity, AbstractLoation, AbstractPolicy, AbstractEnricher, etc.

But should not be overridden by specific entity types. If you do, the entity may break in subsequent releases. Also note that if you require fields to be initialized you must do that in this method. You must *not* rely on field initializers because they may not run until *after* this method (this method is invoked by the constructor in this class, so initializers in subclasses will not have run when this overridden method is invoked.)

Specified by:

configure in interface EntityInternal

Overrides:

configure in class AbstractEntity

Returns:

this entity (i.e. itself)

getQueueNames

public java.util.Collection<java.lang.String> getQueueNames()

Specified by:

getQueueNames in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>

getTopicNames

public java.util.Collection<java.lang.String> getTopicNames()

Specified by:

getTopicNames in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>

getQueues

public java.util.Map<java.lang.String,Q> getQueues()

Specified by:

getQueues in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>

getTopics

public java.util.Map<java.lang.String,T> getTopics()

Specified by:

getTopics in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>

setBrokerUrl

public abstract void setBrokerUrl()

Description copied from interface: MessageBroker

Setup the URL for external connections to the broker.

Specified by:

setBrokerUrl in interface MessageBroker

preStop

public void preStop()

addQueue

public void addQueue(java.lang.String name)

Description copied from interface: JMSBroker

TODO make this an effector

Specified by:

addQueue in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>

checkStartingOrRunning

public void checkStartingOrRunning()

addQueue

public void addQueue(java.lang.String name,
                     java.util.Map properties)

Specified by:

addQueue in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>

createQueue

public abstract Q createQueue(java.util.Map properties)

Specified by:

createQueue in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>

addTopic

public void addTopic(java.lang.String name)

Description copied from interface: JMSBroker

TODO make this an effector

Specified by:

addTopic in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>

addTopic

public void addTopic(java.lang.String name,
                     java.util.Map properties)

Specified by:

addTopic in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>

createTopic

public abstract T createTopic(java.util.Map properties)

Specified by:

createTopic in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>