Overview  Package   Class  Deprecated  Index  Help 
Brooklyn
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

brooklyn.entity.messaging.jms
[Java] Class JMSBroker

java.lang.Object
  groovy.lang.GroovyObjectSupport
      brooklyn.entity.basic.AbstractEntity
          brooklyn.entity.basic.SoftwareProcessImpl
              brooklyn.entity.messaging.jms.JMSBroker
All Implemented Interfaces:
MessageBroker
public abstract class JMSBroker
extends SoftwareProcessImpl
Field Summary
 
Fields inherited from class SoftwareProcessImpl
sensorRegistry
 
Fields inherited from class AbstractEntity
LOG, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED, _subscriptionTracker, attributesInternal, configsInternal, managementSupport, tempWorkings
 
Constructor Summary
JMSBroker()

JMSBroker(java.util.Map properties)

JMSBroker(Entity parent)

JMSBroker(java.util.Map properties, Entity parent)

 
Method Summary
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)

JMSBroker configure(java.util.Map properties)

protected void connectSensors()

Q createQueue(java.util.Map properties)

java.lang.Object createTopic(java.util.Map properties)

java.util.Collection getQueueNames()

java.util.Map getQueues()

java.util.Collection getTopicNames()

java.util.Map getTopics()

protected void postStart()

void preStop()

void setBrokerUrl()

 
Methods inherited from class SoftwareProcessImpl
callRebindHooks, callStartHooks, checkModifiable, connectSensors, connectServiceUpIsRunning, disconnectSensors, disconnectServiceUpIsRunning, doInitDriver, getDriver, getLocalHostname, getMachineOrNull, getProvisioningFlags, getProvisioningLocation, getRequiredOpenPorts, newDriver, obtainProvisioningFlags, onManagementStarted, onManagementStarting, postDriverRestart, postDriverStart, postRebind, postRestart, postStart, preStart, preStop, rebind, restart, setProvisioningLocation, start, startInLocation, startInLocation, startInLocation, startInLocation, stop, stopInLocation, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp
 
Methods inherited from class AbstractEntity
addChild, addChild, addEnricher, addGroup, addLocations, addOwnedChild, addPolicy, assertNotYetOwned, clearOwner, clearParent, configure, configure, configure, configure, configure, createManagementSupport, destroy, emit, emitInternal, equals, finalize, firstLocation, getAllAttributes, getAllConfig, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getChildren, getChildrenReference, getConfig, getConfig, getConfig, getConfig, getConfigMap, getDisplayName, getEffector, getEnrichers, getEntityManager, getEntityType, getEntityTypeName, getExecutionContext, getGroups, getId, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getOwnedChildren, getOwnedChildrenReference, getOwner, getParent, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getSubscriptionTracker, hasEverBeenManaged, hashCode, init, invalidateReferences, invoke, invoke, invokeFromJava, invokeMethod, isLegacyConstruction, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStarted, onManagementStarting, refreshInheritedConfig, refreshInheritedConfigOfChildren, removeAllEnrichers, removeAllPolicies, removeAttribute, removeChild, removeEnricher, removeLocations, removeOwnedChild, removePolicy, setApplication, setAttribute, setAttribute, setAttributeWithoutPublishing, setBeingManaged, setConfig, setConfig, setConfig, setConfig, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setConfigIfValNonNull, setConfigIfValNonNull, setDisplayName, setManagementContext, setOwner, setParent, setProxy, subscribe, subscribeToChildren, subscribeToMembers, toString, toStringFieldsToInclude, toStringHelper, unsubscribe, unsubscribe
 
Methods inherited from class groovy.lang.GroovyObjectSupport
groovy.lang.GroovyObjectSupport#setProperty(java.lang.String, java.lang.Object), groovy.lang.GroovyObjectSupport#getProperty(java.lang.String), groovy.lang.GroovyObjectSupport#getMetaClass(), groovy.lang.GroovyObjectSupport#setMetaClass(groovy.lang.MetaClass), groovy.lang.GroovyObjectSupport#invokeMethod(java.lang.String, java.lang.Object), groovy.lang.GroovyObjectSupport#wait(), groovy.lang.GroovyObjectSupport#wait(long), groovy.lang.GroovyObjectSupport#wait(long, int), groovy.lang.GroovyObjectSupport#equals(java.lang.Object), groovy.lang.GroovyObjectSupport#toString(), groovy.lang.GroovyObjectSupport#hashCode(), groovy.lang.GroovyObjectSupport#getClass(), groovy.lang.GroovyObjectSupport#notify(), groovy.lang.GroovyObjectSupport#notifyAll()
 

Constructor Detail

JMSBroker

public JMSBroker()

JMSBroker

public JMSBroker(java.util.Map properties)

JMSBroker

public JMSBroker(Entity parent)

JMSBroker

public JMSBroker(java.util.Map properties, Entity parent)

 
Method Detail

addQueue

public void addQueue(java.lang.String name)
TODO make this an effector

addQueue

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

addTopic

public void addTopic(java.lang.String name)
TODO make this an effector

addTopic

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

configure

public JMSBroker configure(java.util.Map properties)

connectSensors

@Override
protected void connectSensors()

createQueue

public Q createQueue(java.util.Map properties)

createTopic

public java.lang.Object createTopic(java.util.Map properties)

getQueueNames

@VisibleForTesting
public java.util.Collection getQueueNames()

getQueues

@VisibleForTesting
public java.util.Map getQueues()

getTopicNames

@VisibleForTesting
public java.util.Collection getTopicNames()

getTopics

@VisibleForTesting
public java.util.Map getTopics()

postStart

@Override
protected void postStart()

preStop

@Override
public void preStop()

setBrokerUrl

public void setBrokerUrl()

 

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