Brooklyn

brooklyn.entity.messaging.qpid
[Java] Class QpidDestinationImpl

java.lang.Object
  brooklyn.entity.basic.AbstractEntity
      brooklyn.entity.messaging.jms.JMSDestinationImpl
          brooklyn.entity.messaging.qpid.QpidDestinationImpl
All Implemented Interfaces:
QpidDestination

public abstract class QpidDestinationImpl
extends JMSDestinationImpl

Field Summary
protected javax.management.ObjectName exchange

protected JmxFeed jmxFeed

protected JmxHelper jmxHelper

static Logger log

protected javax.management.ObjectName virtualHostManager

 
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
QpidDestinationImpl()

 
Method Summary
void create()

void delete()

protected void disconnectSensors()

QpidBroker getParent()

java.lang.String getQueueName()

void onManagementStarting()

 
Methods inherited from class JMSDestinationImpl
connectSensors, delete, destroy, disconnectSensors, getName, onManagementStarting
 
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
 

Field Detail

exchange

protected javax.management.ObjectName exchange


jmxFeed

protected JmxFeed jmxFeed


jmxHelper

protected JmxHelper jmxHelper


log

public static final Logger log


virtualHostManager

protected javax.management.ObjectName virtualHostManager


 
Constructor Detail

QpidDestinationImpl

public QpidDestinationImpl()


 
Method Detail

create

jmxHelper.operation(virtualHostManager, "createNewQueue", getName(), getParent().getAttribute(Attributes.JMX_USER), true);
public void create()


delete

jmxHelper.operation(exchange, "removeBinding", getName(), getName());
public void delete()


disconnectSensors

if (jmxFeed != null) jmxFeed.stop();
protected void disconnectSensors()


getParent

@Override
public QpidBroker getParent()


getQueueName

public java.lang.String getQueueName()


onManagementStarting

@Override
public void onManagementStarting()


 

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