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 JMSBrokerImpl

java.lang.Object
  brooklyn.entity.basic.AbstractEntity
      brooklyn.entity.basic.SoftwareProcessImpl
          brooklyn.entity.messaging.jms.JMSBrokerImpl
All Implemented Interfaces:
JMSBroker
public abstract class JMSBrokerImpl
extends SoftwareProcessImpl
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
JMSBrokerImpl()

 
Method Summary
void addQueue(java.lang.String name)

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

void addTopic(java.lang.String name)

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

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

JMSBrokerImpl

public JMSBrokerImpl()

 
Method Detail

addQueue

@Override
public void addQueue(java.lang.String name)

addQueue

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

addTopic

@Override
public void addTopic(java.lang.String name)

addTopic

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

configure

@Override
public JMSBrokerImpl configure(java.util.Map properties)

connectSensors

@Override
protected void connectSensors()

createQueue

addTopic(name, MutableMap.of());
public Q createQueue(java.util.Map properties)

createTopic

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

getQueueNames

@Override
public java.util.Collection getQueueNames()

getQueues

@Override
public java.util.Map getQueues()

getTopicNames

@Override
public java.util.Collection getTopicNames()

getTopics

@Override
public java.util.Map getTopics()

postStart

protected void postStart() {
		su
protected void postStart()

preStop

// (e.g. in CI have seen activemq "BrokerStoppedException" thrown in queue.destroy()).
public void preStop()

setBrokerUrl

@Override
public void setBrokerUrl()

 

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