public class RabbitQueue extends RabbitDestination implements Queue
EntityInternal.FeedSupport
BrooklynObjectInternal.ConfigurationSupportInternal
BrooklynObject.TagSupport
Configurable.ConfigurationSupport
log
CHILD_ADDED, CHILD_REMOVED, EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, LOCATION_ADDED, LOCATION_REMOVED, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED
QUEUE_DEPTH_BYTES, QUEUE_DEPTH_MESSAGES, QUEUE_NAME
DIRECT, EXCHANGE_NAME, TOPIC
Constructor and Description |
---|
RabbitQueue() |
Modifier and Type | Method and Description |
---|---|
void |
create()
Create the queue.
|
java.lang.String |
getName() |
java.lang.String |
getQueueName()
Return the AMQP name for the queue.
|
delete, getDefaultExchangeName, getExchangeName, getParent, getVirtualHost, onManagementStarting
addChild, addChild, addEnricher, addEnricher, addFeed, addGroup, addLocations, addPolicy, addPolicy, addTag, clearLocations, clearParent, config, configure, 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, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getTags, hashCode, init, invalidateReferences, invoke, invoke, invoke, modifyAttribute, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStarted, 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, unsubscribe
getCatalogItemId, getId, getTagSupport, rebind, setCatalogItemId, tags
setCatalogItemId
getCatalogItemId, getTagSupport, tags
public java.lang.String getName()
public void create()
Queue
create
in interface Queue
create
in class RabbitDestination
public java.lang.String getQueueName()
getQueueName
in interface Queue