public class ExchangeMBean extends AMQManagedObject implements ManagedExchange
| Modifier and Type | Field and Description |
|---|---|
static String |
FANOUT_EXCHANGE_TYPE |
static String |
HEADERS_EXCHANGE_TYPE |
BINDING_KEY, COMPOSITE_ITEM_DESCRIPTIONS, COMPOSITE_ITEM_NAMES, HDR_BINDING_NUMBER, HDR_QUEUE_BINDINGS, HDR_QUEUE_NAME, HEADERS_COMPOSITE_ITEM_DESC, HEADERS_COMPOSITE_ITEM_NAMES, HEADERS_TABULAR_UNIQUE_INDEX, QUEUE_NAMES, TABULAR_UNIQUE_INDEX, TYPEDOMAIN| Modifier | Constructor and Description |
|---|---|
protected |
ExchangeMBean(Exchange exchange,
VirtualHostMBean virtualHostMBean) |
| Modifier and Type | Method and Description |
|---|---|
TabularData |
bindings()
Returns all the bindings this exchange has with the queues.
|
void |
createNewBinding(String queueName,
String binding)
Creates new binding with the given queue and binding.
|
void |
createNewBinding(String queueName,
String binding,
Map<String,Object> arguments)
Creates new binding with the given queue using given binding key and binding arguments.
|
String |
getExchangeType() |
String |
getName()
Returns the name of the managed exchange.
|
String |
getObjectInstanceName() |
ObjectName |
getObjectName()
Created the ObjectName as per the JMX Specs
|
ManagedObject |
getParentObject() |
Integer |
getTicketNo() |
boolean |
isAutoDelete()
Tells if the exchange is set for autodelete or not.
|
boolean |
isDurable()
Tells if the exchange is durable or not.
|
void |
removeBinding(String queueName,
String bindingKey)
Removes an exchange binding from a queue.
|
addNotificationListener, getBroadcaster, incrementAndGetSequenceNumber, removeNotificationListenergetHierarchicalName, getHierarchicalType, getManagementInterface, getMBeanInfo, getNotificationInfo, getObjectNameForSingleInstanceMBean, getRegistry, getType, register, toString, unregistercacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementationclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetNotificationInfopublic static final String FANOUT_EXCHANGE_TYPE
public static final String HEADERS_EXCHANGE_TYPE
protected ExchangeMBean(Exchange exchange, VirtualHostMBean virtualHostMBean) throws JMException
JMExceptionpublic String getObjectInstanceName()
getObjectInstanceName in interface ManagedObjectpublic ManagedObject getParentObject()
getParentObject in interface ManagedObjectgetParentObject in class DefaultManagedObjectpublic ObjectName getObjectName() throws MalformedObjectNameException
DefaultManagedObjectgetObjectName in interface ManagedObjectgetObjectName in class DefaultManagedObjectMalformedObjectNameExceptionpublic String getName()
ManagedExchangegetName in interface ManagedExchangepublic String getExchangeType()
getExchangeType in interface ManagedExchangepublic Integer getTicketNo()
getTicketNo in interface ManagedExchangepublic boolean isDurable()
ManagedExchangeisDurable in interface ManagedExchangepublic boolean isAutoDelete()
ManagedExchangeisAutoDelete in interface ManagedExchangepublic TabularData bindings() throws IOException, JMException
ManagedExchangebindings in interface ManagedExchangeIOExceptionJMExceptionpublic void createNewBinding(String queueName, String binding) throws JMException
ManagedExchangecreateNewBinding in interface ManagedExchangeJMExceptionpublic void createNewBinding(String queueName, String binding, Map<String,Object> arguments) throws JMException
ManagedExchangecreateNewBinding in interface ManagedExchangeJMExceptionpublic void removeBinding(String queueName, String bindingKey) throws IOException, JMException
ManagedExchangeremoveBinding in interface ManagedExchangequeueName - the Queue namebindingKey - the binding keyIOExceptionJMExceptionCopyright © 2006–2016 The Apache Software Foundation. All rights reserved.