Brooklyn

brooklyn.entity.messaging.rabbit
[Java] Class RabbitQueue

java.lang.Object
  brooklyn.entity.basic.AbstractEntity
      brooklyn.entity.messaging.rabbit.RabbitDestination
          brooklyn.entity.messaging.rabbit.RabbitQueue
All Implemented Interfaces:
Queue

public class RabbitQueue
extends RabbitDestination

Field Summary
 
Fields inherited from class RabbitDestination
log, machine, shellEnvironment
 
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
RabbitQueue()

 
Method Summary
protected void connectSensors()

void create()

protected void disconnectSensors()

java.lang.String getName()

java.lang.String getQueueName()

Return the AMQP name for the queue.

 
Methods inherited from class RabbitDestination
connectSensors, create, delete, disconnectSensors, getDefaultExchangeName, getExchangeName, getParent, getVirtualHost, onManagementStarting, toStringHelper
 
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

RabbitQueue

public RabbitQueue()


 
Method Detail

connectSensors

@Override
protected void connectSensors()


create

@Override
public void create()


disconnectSensors

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


getName

public java.lang.String getName()


getQueueName

public java.lang.String getQueueName()
Return the AMQP name for the queue.


 

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