public abstract class JMSBrokerImpl<Q extends JMSDestination & Queue,T extends JMSDestination & Topic> extends SoftwareProcessImpl implements JMSBroker<Q,T>
SoftwareProcess.ChildStartableMode, SoftwareProcess.RestartSoftwareParameters, SoftwareProcess.StopSoftwareParametersStartable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBodyBrooklynObject.TagSupportConfigurable.ConfigurationSupportEntityInternal.FeedSupportBrooklynObjectInternal.ConfigurationSupportInternalCHILD_ADDED, CHILD_REMOVED, EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, LOCATION_ADDED, LOCATION_REMOVED, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVEDADDRESS, CHILDREN_STARTABLE_MODE, CUSTOMIZE_LATCH, DOWNLOAD_ADDON_URLS, DOWNLOAD_URL, 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_INSTALL_FILES, PRE_INSTALL_TEMPLATES, PRE_LAUNCH_COMMAND, PROVISIONING_LOCATION, PROVISIONING_PROPERTIES, REQUIRED_OPEN_LOGIN_PORTS, RUN_DIR, RUNTIME_FILES, RUNTIME_RESOURCES_LATCH, RUNTIME_TEMPLATES, SERVICE_PROCESS_IS_RUNNING, SERVICE_STATE_ACTUAL, SERVICE_STATE_EXPECTED, SETUP_LATCH, SHELL_ENVIRONMENT, SKIP_ENTITY_START_IF_RUNNING, SKIP_INSTALLATION, START_LATCH, START_TIMEOUT, SUBNET_ADDRESS, SUBNET_HOSTNAME, SUGGESTED_INSTALL_DIR, SUGGESTED_RUN_DIR, SUGGESTED_VERSIONRESTART, SERVICE_UP, START, STOPBROKER_URL| Constructor and Description |
|---|
JMSBrokerImpl() |
| 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.
|
checkModifiable, getDriver, getLocalHostname, init, onManagementStarted, onManagementStarting, rebind, restart, start, stop, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp, waitForServiceUpaddChild, addChild, addEnricher, addEnricher, addFeed, addGroup, addLocations, addPolicy, addPolicy, addTag, clearLocations, clearParent, config, 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, unsubscribegetCatalogItemId, getId, getTagSupport, setCatalogItemId, tagsaddChild, 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, setParentgetCatalogItemId, getTagSupport, tagsconfig, setConfiggetDriverInterfacesetCatalogItemIdpublic JMSBrokerImpl configure(java.util.Map properties)
AbstractBrooklynObjectConfigBag.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.)
configure in interface EntityInternalconfigure in class AbstractEntitypublic java.util.Collection<java.lang.String> getQueueNames()
getQueueNames in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>public java.util.Collection<java.lang.String> getTopicNames()
getTopicNames in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>public java.util.Map<java.lang.String,Q> getQueues()
getQueues in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>public java.util.Map<java.lang.String,T> getTopics()
getTopics in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>public abstract void setBrokerUrl()
MessageBrokersetBrokerUrl in interface MessageBrokerpublic void preStop()
public void addQueue(java.lang.String name)
JMSBrokeraddQueue in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>public void checkStartingOrRunning()
public void addQueue(java.lang.String name,
java.util.Map properties)
addQueue in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>public abstract Q createQueue(java.util.Map properties)
createQueue in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>public void addTopic(java.lang.String name)
JMSBrokeraddTopic in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>public void addTopic(java.lang.String name,
java.util.Map properties)
addTopic in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>public abstract T createTopic(java.util.Map properties)
createTopic in interface JMSBroker<Q extends JMSDestination & Queue,T extends JMSDestination & Topic>