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, TYPE
DOMAIN
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, removeNotificationListener
getHierarchicalName, getHierarchicalType, getManagementInterface, getMBeanInfo, getNotificationInfo, getObjectNameForSingleInstanceMBean, getRegistry, getType, register, toString, unregister
cacheMBeanInfo, 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, setImplementation
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getNotificationInfo
public static final String FANOUT_EXCHANGE_TYPE
public static final String HEADERS_EXCHANGE_TYPE
protected ExchangeMBean(Exchange exchange, VirtualHostMBean virtualHostMBean) throws JMException
JMException
public String getObjectInstanceName()
getObjectInstanceName
in interface ManagedObject
public ManagedObject getParentObject()
getParentObject
in interface ManagedObject
getParentObject
in class DefaultManagedObject
public ObjectName getObjectName() throws MalformedObjectNameException
DefaultManagedObject
getObjectName
in interface ManagedObject
getObjectName
in class DefaultManagedObject
MalformedObjectNameException
public String getName()
ManagedExchange
getName
in interface ManagedExchange
public String getExchangeType()
getExchangeType
in interface ManagedExchange
public Integer getTicketNo()
getTicketNo
in interface ManagedExchange
public boolean isDurable()
ManagedExchange
isDurable
in interface ManagedExchange
public boolean isAutoDelete()
ManagedExchange
isAutoDelete
in interface ManagedExchange
public TabularData bindings() throws IOException, JMException
ManagedExchange
bindings
in interface ManagedExchange
IOException
JMException
public void createNewBinding(String queueName, String binding) throws JMException
ManagedExchange
createNewBinding
in interface ManagedExchange
JMException
public void createNewBinding(String queueName, String binding, Map<String,Object> arguments) throws JMException
ManagedExchange
createNewBinding
in interface ManagedExchange
JMException
public void removeBinding(String queueName, String bindingKey) throws IOException, JMException
ManagedExchange
removeBinding
in interface ManagedExchange
queueName
- the Queue namebindingKey
- the binding keyIOException
JMException
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.