org.apache.qpid.server.virtualhost
Class VirtualHostImpl
java.lang.Object
org.apache.qpid.server.virtualhost.VirtualHostImpl
- All Implemented Interfaces:
- org.apache.qpid.common.Closeable, ConfiguredObject<VirtualHostConfigType,VirtualHostConfig>, VirtualHostConfig, DurableConfigurationStore.Source, VirtualHost
public class VirtualHostImpl
- extends Object
- implements VirtualHost
Method Summary |
void |
close()
|
void |
createBrokerConnection(String transport,
String host,
int port,
String vhost,
boolean durable,
String authMechanism,
String username,
String password)
|
IApplicationRegistry |
getApplicationRegistry()
|
AuthenticationManager |
getAuthenticationManager()
|
BindingFactory |
getBindingFactory()
|
BrokerConfig |
getBroker()
|
UUID |
getBrokerId()
|
ManagedObject |
getBrokerMBean()
|
ConfigStore |
getConfigStore()
|
VirtualHostConfigType |
getConfigType()
|
VirtualHostConfiguration |
getConfiguration()
|
IConnectionRegistry |
getConnectionRegistry()
|
long |
getCreateTime()
|
DurableConfigurationStore |
getDurableConfigurationStore()
|
ExchangeFactory |
getExchangeFactory()
|
ExchangeRegistry |
getExchangeRegistry()
|
String |
getFederationTag()
|
int |
getHouseKeepingActiveCount()
|
long |
getHouseKeepingCompletedTaskCount()
|
int |
getHouseKeepingPoolSize()
|
long |
getHouseKeepingTaskCount()
|
UUID |
getId()
|
ManagedObject |
getManagedObject()
|
MessageStore |
getMessageStore()
|
String |
getName()
|
ConfiguredObject |
getParent()
|
QueueRegistry |
getQueueRegistry()
|
SecurityManager |
getSecurityManager()
|
TransactionLog |
getTransactionLog()
|
boolean |
isDurable()
|
void |
removeBrokerConnection(BrokerLink blink)
|
void |
removeBrokerConnection(String transport,
String host,
int port,
String vhost)
|
void |
scheduleHouseKeepingTask(long period,
HouseKeepingTask task)
Allow other broker components to register a HouseKeepingTask |
void |
setBroker(BrokerConfig broker)
|
void |
setHouseKeepingPoolSize(int newSize)
|
String |
toString()
|
_virtualHostMBean
protected VirtualHostImpl.VirtualHostMBean _virtualHostMBean
VirtualHostImpl
public VirtualHostImpl(IApplicationRegistry appRegistry,
VirtualHostConfiguration hostConfig)
throws Exception
- Throws:
Exception
VirtualHostImpl
public VirtualHostImpl(VirtualHostConfiguration hostConfig,
MessageStore store)
throws Exception
- Throws:
Exception
getConnectionRegistry
public IConnectionRegistry getConnectionRegistry()
- Specified by:
getConnectionRegistry
in interface VirtualHost
getConfiguration
public VirtualHostConfiguration getConfiguration()
- Specified by:
getConfiguration
in interface VirtualHost
getId
public UUID getId()
- Specified by:
getId
in interface ConfiguredObject<VirtualHostConfigType,VirtualHostConfig>
getConfigType
public VirtualHostConfigType getConfigType()
- Specified by:
getConfigType
in interface ConfiguredObject<VirtualHostConfigType,VirtualHostConfig>
getParent
public ConfiguredObject getParent()
- Specified by:
getParent
in interface ConfiguredObject<VirtualHostConfigType,VirtualHostConfig>
isDurable
public boolean isDurable()
- Specified by:
isDurable
in interface ConfiguredObject<VirtualHostConfigType,VirtualHostConfig>
scheduleHouseKeepingTask
public void scheduleHouseKeepingTask(long period,
HouseKeepingTask task)
- Allow other broker components to register a HouseKeepingTask
- Specified by:
scheduleHouseKeepingTask
in interface VirtualHost
- Parameters:
period
- How often this task should run, in ms.task
- The task to run.
getHouseKeepingTaskCount
public long getHouseKeepingTaskCount()
- Specified by:
getHouseKeepingTaskCount
in interface VirtualHost
getHouseKeepingCompletedTaskCount
public long getHouseKeepingCompletedTaskCount()
- Specified by:
getHouseKeepingCompletedTaskCount
in interface VirtualHost
getHouseKeepingPoolSize
public int getHouseKeepingPoolSize()
- Specified by:
getHouseKeepingPoolSize
in interface VirtualHost
setHouseKeepingPoolSize
public void setHouseKeepingPoolSize(int newSize)
- Specified by:
setHouseKeepingPoolSize
in interface VirtualHost
getHouseKeepingActiveCount
public int getHouseKeepingActiveCount()
- Specified by:
getHouseKeepingActiveCount
in interface VirtualHost
getName
public String getName()
- Specified by:
getName
in interface VirtualHostConfig
- Specified by:
getName
in interface VirtualHost
getBroker
public BrokerConfig getBroker()
- Specified by:
getBroker
in interface VirtualHostConfig
getFederationTag
public String getFederationTag()
- Specified by:
getFederationTag
in interface VirtualHostConfig
setBroker
public void setBroker(BrokerConfig broker)
- Specified by:
setBroker
in interface VirtualHostConfig
getCreateTime
public long getCreateTime()
- Specified by:
getCreateTime
in interface ConfiguredObject<VirtualHostConfigType,VirtualHostConfig>
getQueueRegistry
public QueueRegistry getQueueRegistry()
- Specified by:
getQueueRegistry
in interface VirtualHost
getExchangeRegistry
public ExchangeRegistry getExchangeRegistry()
- Specified by:
getExchangeRegistry
in interface VirtualHost
getExchangeFactory
public ExchangeFactory getExchangeFactory()
- Specified by:
getExchangeFactory
in interface VirtualHost
getMessageStore
public MessageStore getMessageStore()
- Specified by:
getMessageStore
in interface VirtualHost
getTransactionLog
public TransactionLog getTransactionLog()
- Specified by:
getTransactionLog
in interface VirtualHost
getDurableConfigurationStore
public DurableConfigurationStore getDurableConfigurationStore()
- Specified by:
getDurableConfigurationStore
in interface DurableConfigurationStore.Source
- Specified by:
getDurableConfigurationStore
in interface VirtualHost
getAuthenticationManager
public AuthenticationManager getAuthenticationManager()
- Specified by:
getAuthenticationManager
in interface VirtualHost
getSecurityManager
public SecurityManager getSecurityManager()
- Specified by:
getSecurityManager
in interface VirtualHost
close
public void close()
- Specified by:
close
in interface org.apache.qpid.common.Closeable
- Specified by:
close
in interface VirtualHost
getBrokerMBean
public ManagedObject getBrokerMBean()
getManagedObject
public ManagedObject getManagedObject()
- Specified by:
getManagedObject
in interface VirtualHost
getBrokerId
public UUID getBrokerId()
- Specified by:
getBrokerId
in interface VirtualHost
getApplicationRegistry
public IApplicationRegistry getApplicationRegistry()
- Specified by:
getApplicationRegistry
in interface VirtualHost
getBindingFactory
public BindingFactory getBindingFactory()
- Specified by:
getBindingFactory
in interface VirtualHost
createBrokerConnection
public void createBrokerConnection(String transport,
String host,
int port,
String vhost,
boolean durable,
String authMechanism,
String username,
String password)
- Specified by:
createBrokerConnection
in interface VirtualHost
removeBrokerConnection
public void removeBrokerConnection(String transport,
String host,
int port,
String vhost)
removeBrokerConnection
public void removeBrokerConnection(BrokerLink blink)
- Specified by:
removeBrokerConnection
in interface VirtualHost
getConfigStore
public ConfigStore getConfigStore()
- Specified by:
getConfigStore
in interface VirtualHost
toString
public String toString()
- Overrides:
toString
in class Object
Licensed to the Apache Software Foundation