public class HornetQServerControlImpl extends AbstractControl implements HornetQServerControl, NotificationEmitter, NotificationListener
storageManager
Constructor and Description |
---|
HornetQServerControlImpl(PostOffice postOffice,
Configuration configuration,
ResourceManager resourceManager,
RemotingService remotingService,
HornetQServer messagingServer,
MessageCounterManager messageCounterManager,
StorageManager storageManager,
NotificationBroadcasterSupport broadcaster) |
blockOnIO, clearIO, getMBeanInfo
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
public HornetQServerControlImpl(PostOffice postOffice, Configuration configuration, ResourceManager resourceManager, RemotingService remotingService, HornetQServer messagingServer, MessageCounterManager messageCounterManager, StorageManager storageManager, NotificationBroadcasterSupport broadcaster) throws Exception
Exception
public boolean isStarted()
isStarted
in interface HornetQServerControl
public String getVersion()
getVersion
in interface HornetQServerControl
public boolean isBackup()
isBackup
in interface HornetQServerControl
public boolean isSharedStore()
isSharedStore
in interface HornetQServerControl
public String getBindingsDirectory()
getBindingsDirectory
in interface HornetQServerControl
public String[] getInterceptorClassNames()
getInterceptorClassNames
in interface HornetQServerControl
public String[] getIncomingInterceptorClassNames()
getIncomingInterceptorClassNames
in interface HornetQServerControl
public String[] getOutgoingInterceptorClassNames()
getOutgoingInterceptorClassNames
in interface HornetQServerControl
public int getJournalBufferSize()
getJournalBufferSize
in interface HornetQServerControl
public int getJournalBufferTimeout()
getJournalBufferTimeout
in interface HornetQServerControl
public void setFailoverOnServerShutdown(boolean failoverOnServerShutdown)
setFailoverOnServerShutdown
in interface HornetQServerControl
public boolean isFailoverOnServerShutdown()
isFailoverOnServerShutdown
in interface HornetQServerControl
public int getJournalMaxIO()
getJournalMaxIO
in interface HornetQServerControl
public String getJournalDirectory()
getJournalDirectory
in interface HornetQServerControl
public int getJournalFileSize()
getJournalFileSize
in interface HornetQServerControl
public int getJournalMinFiles()
getJournalMinFiles
in interface HornetQServerControl
public int getJournalCompactMinFiles()
getJournalCompactMinFiles
in interface HornetQServerControl
public int getJournalCompactPercentage()
getJournalCompactPercentage
in interface HornetQServerControl
public boolean isPersistenceEnabled()
isPersistenceEnabled
in interface HornetQServerControl
public String getJournalType()
getJournalType
in interface HornetQServerControl
public String getPagingDirectory()
getPagingDirectory
in interface HornetQServerControl
public int getScheduledThreadPoolMaxSize()
getScheduledThreadPoolMaxSize
in interface HornetQServerControl
public int getThreadPoolMaxSize()
getThreadPoolMaxSize
in interface HornetQServerControl
public long getSecurityInvalidationInterval()
getSecurityInvalidationInterval
in interface HornetQServerControl
public boolean isClustered()
isClustered
in interface HornetQServerControl
public boolean isCreateBindingsDir()
isCreateBindingsDir
in interface HornetQServerControl
public boolean isCreateJournalDir()
isCreateJournalDir
in interface HornetQServerControl
public boolean isJournalSyncNonTransactional()
isJournalSyncNonTransactional
in interface HornetQServerControl
public boolean isJournalSyncTransactional()
isJournalSyncTransactional
in interface HornetQServerControl
public boolean isSecurityEnabled()
isSecurityEnabled
in interface HornetQServerControl
public boolean isAsyncConnectionExecutionEnabled()
isAsyncConnectionExecutionEnabled
in interface HornetQServerControl
public void deployQueue(String address, String name, String filterString) throws Exception
deployQueue
in interface HornetQServerControl
Exception
public void deployQueue(String address, String name, String filterStr, boolean durable) throws Exception
deployQueue
in interface HornetQServerControl
Exception
public void createQueue(String address, String name) throws Exception
createQueue
in interface HornetQServerControl
Exception
public void createQueue(String address, String name, boolean durable) throws Exception
createQueue
in interface HornetQServerControl
Exception
public void createQueue(String address, String name, String filterStr, boolean durable) throws Exception
createQueue
in interface HornetQServerControl
Exception
public String[] getQueueNames()
getQueueNames
in interface HornetQServerControl
public String[] getAddressNames()
getAddressNames
in interface HornetQServerControl
public void destroyQueue(String name) throws Exception
destroyQueue
in interface HornetQServerControl
Exception
public int getConnectionCount()
getConnectionCount
in interface HornetQServerControl
public void enableMessageCounters()
enableMessageCounters
in interface HornetQServerControl
public void disableMessageCounters()
disableMessageCounters
in interface HornetQServerControl
public void resetAllMessageCounters()
resetAllMessageCounters
in interface HornetQServerControl
public void resetAllMessageCounterHistories()
resetAllMessageCounterHistories
in interface HornetQServerControl
public boolean isMessageCounterEnabled()
isMessageCounterEnabled
in interface HornetQServerControl
public long getMessageCounterSamplePeriod()
getMessageCounterSamplePeriod
in interface HornetQServerControl
public void setMessageCounterSamplePeriod(long newPeriod)
setMessageCounterSamplePeriod
in interface HornetQServerControl
public int getMessageCounterMaxDayCount()
getMessageCounterMaxDayCount
in interface HornetQServerControl
public void setMessageCounterMaxDayCount(int count)
setMessageCounterMaxDayCount
in interface HornetQServerControl
public String[] listPreparedTransactions()
listPreparedTransactions
in interface HornetQServerControl
public String listPreparedTransactionDetailsAsJSON() throws Exception
listPreparedTransactionDetailsAsJSON
in interface HornetQServerControl
Exception
public String listPreparedTransactionDetailsAsHTML() throws Exception
listPreparedTransactionDetailsAsHTML
in interface HornetQServerControl
Exception
public String[] listHeuristicCommittedTransactions()
listHeuristicCommittedTransactions
in interface HornetQServerControl
public String[] listHeuristicRolledBackTransactions()
listHeuristicRolledBackTransactions
in interface HornetQServerControl
public boolean commitPreparedTransaction(String transactionAsBase64) throws Exception
commitPreparedTransaction
in interface HornetQServerControl
Exception
public boolean rollbackPreparedTransaction(String transactionAsBase64) throws Exception
rollbackPreparedTransaction
in interface HornetQServerControl
Exception
public String[] listRemoteAddresses()
listRemoteAddresses
in interface HornetQServerControl
public String[] listRemoteAddresses(String ipAddress)
listRemoteAddresses
in interface HornetQServerControl
public boolean closeConnectionsForAddress(String ipAddress)
closeConnectionsForAddress
in interface HornetQServerControl
public boolean closeConsumerConnectionsForAddress(String address)
closeConsumerConnectionsForAddress
in interface HornetQServerControl
public boolean closeConnectionsForUser(String userName)
closeConnectionsForUser
in interface HornetQServerControl
public String[] listConnectionIDs()
listConnectionIDs
in interface HornetQServerControl
public String[] listSessions(String connectionID)
listSessions
in interface HornetQServerControl
public String listProducersInfoAsJSON() throws Exception
listProducersInfoAsJSON
in interface HornetQServerControl
Exception
public Object[] getConnectors() throws Exception
getConnectors
in interface HornetQServerControl
Exception
public String getConnectorsAsJSON() throws Exception
getConnectorsAsJSON
in interface HornetQServerControl
Exception
public void addSecuritySettings(String addressMatch, String sendRoles, String consumeRoles, String createDurableQueueRoles, String deleteDurableQueueRoles, String createNonDurableQueueRoles, String deleteNonDurableQueueRoles, String manageRoles) throws Exception
addSecuritySettings
in interface HornetQServerControl
Exception
public void removeSecuritySettings(String addressMatch) throws Exception
removeSecuritySettings
in interface HornetQServerControl
Exception
public Object[] getRoles(String addressMatch) throws Exception
getRoles
in interface HornetQServerControl
Exception
public String getRolesAsJSON(String addressMatch) throws Exception
getRolesAsJSON
in interface HornetQServerControl
Exception
public String getAddressSettingsAsJSON(String address) throws Exception
getAddressSettingsAsJSON
in interface HornetQServerControl
Exception
public void addAddressSettings(String address, String DLA, String expiryAddress, long expiryDelay, boolean lastValueQueue, int deliveryAttempts, long maxSizeBytes, int pageSizeBytes, int pageMaxCacheSize, long redeliveryDelay, double redeliveryMultiplier, long maxRedeliveryDelay, long redistributionDelay, boolean sendToDLAOnNoRoute, String addressFullMessagePolicy, long slowConsumerThreshold, long slowConsumerCheckPeriod, String slowConsumerPolicy) throws Exception
addAddressSettings
in interface HornetQServerControl
Exception
public void removeAddressSettings(String addressMatch) throws Exception
removeAddressSettings
in interface HornetQServerControl
Exception
public void sendQueueInfoToQueue(String queueName, String address) throws Exception
sendQueueInfoToQueue
in interface HornetQServerControl
Exception
public String[] getDivertNames()
getDivertNames
in interface HornetQServerControl
public void createDivert(String name, String routingName, String address, String forwardingAddress, boolean exclusive, String filterString, String transformerClassName) throws Exception
createDivert
in interface HornetQServerControl
Exception
public void destroyDivert(String name) throws Exception
destroyDivert
in interface HornetQServerControl
Exception
public String[] getBridgeNames()
getBridgeNames
in interface HornetQServerControl
public void createBridge(String name, String queueName, String forwardingAddress, String filterString, String transformerClassName, long retryInterval, double retryIntervalMultiplier, int initialConnectAttempts, int reconnectAttempts, boolean useDuplicateDetection, int confirmationWindowSize, long clientFailureCheckPeriod, String connectorNames, boolean useDiscoveryGroup, boolean ha, String user, String password) throws Exception
createBridge
in interface HornetQServerControl
Exception
public void destroyBridge(String name) throws Exception
destroyBridge
in interface HornetQServerControl
Exception
public void forceFailover() throws Exception
forceFailover
in interface HornetQServerControl
Exception
public void removeNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws ListenerNotFoundException
removeNotificationListener
in interface NotificationEmitter
ListenerNotFoundException
public void removeNotificationListener(NotificationListener listener) throws ListenerNotFoundException
removeNotificationListener
in interface NotificationBroadcaster
ListenerNotFoundException
public void addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws IllegalArgumentException
addNotificationListener
in interface NotificationBroadcaster
IllegalArgumentException
public MBeanNotificationInfo[] getNotificationInfo()
getNotificationInfo
in interface NotificationBroadcaster
public long getConnectionTTLOverride()
getConnectionTTLOverride
in interface HornetQServerControl
public int getIDCacheSize()
getIDCacheSize
in interface HornetQServerControl
public String getLargeMessagesDirectory()
getLargeMessagesDirectory
in interface HornetQServerControl
public String getManagementAddress()
getManagementAddress
in interface HornetQServerControl
public String getManagementNotificationAddress()
getManagementNotificationAddress
in interface HornetQServerControl
public long getMessageExpiryScanPeriod()
getMessageExpiryScanPeriod
in interface HornetQServerControl
public long getMessageExpiryThreadPriority()
getMessageExpiryThreadPriority
in interface HornetQServerControl
public long getTransactionTimeout()
getTransactionTimeout
in interface HornetQServerControl
public long getTransactionTimeoutScanPeriod()
getTransactionTimeoutScanPeriod
in interface HornetQServerControl
public boolean isPersistDeliveryCountBeforeDelivery()
isPersistDeliveryCountBeforeDelivery
in interface HornetQServerControl
public boolean isPersistIDCache()
isPersistIDCache
in interface HornetQServerControl
public boolean isWildcardRoutingEnabled()
isWildcardRoutingEnabled
in interface HornetQServerControl
protected MBeanOperationInfo[] fillMBeanOperationInfo()
fillMBeanOperationInfo
in class AbstractControl
public void onNotification(Notification notification)
onNotification
in interface NotificationListener
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.