|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface HornetQServerControl
A HornetQServerControl is used to manage HornetQ servers.
Method Summary | |
---|---|
boolean |
closeConnectionsForAddress(String ipAddress)
Closes all the connections of clients connected to this server which matches the specified IP address. |
boolean |
commitPreparedTransaction(String transactionAsBase64)
Heuristically commits a prepared transaction. |
void |
createQueue(String address,
String name)
Create a durable queue. |
void |
createQueue(String address,
String name,
boolean durable)
Create a queue. |
void |
createQueue(String address,
String name,
String filter,
boolean durable)
Create a queue. |
void |
deployQueue(String address,
String name,
String filter)
Deploy a durable queue. |
void |
deployQueue(String address,
String name,
String filter,
boolean durable)
Deploy a queue. |
void |
destroyQueue(String name)
Destroys the queue corresponding to the specified name. |
void |
disableMessageCounters()
Disables message counters for this server. |
void |
enableMessageCounters()
Enables message counters for this server. |
String[] |
getAddressNames()
Returns the addresses created on this server. |
String |
getBackupConnectorName()
Returns the name of the connector used to connect to the backup. |
String |
getBindingsDirectory()
Returns the file system directory used to store bindings. |
int |
getConnectionCount()
Returns the number of connections connected to this server. |
long |
getConnectionTTLOverride()
Returns the connection time to live. |
Object[] |
getConnectors()
Returns the connectors configured for this server. |
String |
getConnectorsAsJSON()
Returns the connectors configured for this server using JSON serialization. |
int |
getIDCacheSize()
Returns the size of the cache for pre-creating message IDs. |
String[] |
getInterceptorClassNames()
Returns the list of interceptors used by this server. |
int |
getJournalBufferSize()
Returns the size of the internal buffer on the journal. |
int |
getJournalBufferTimeout()
Returns the timeout (in nanoseconds) used to flush internal buffers on the journal. |
int |
getJournalCompactMinFiles()
Returns the minimal number of journal files before compacting. |
int |
getJournalCompactPercentage()
Return the percentage of live data before compacting the journal. |
String |
getJournalDirectory()
Returns the file system directory used to store journal log. |
int |
getJournalFileSize()
Returns the size (in bytes) of each journal files. |
int |
getJournalMaxIO()
Returns the maximum number of write requests that can be in the AIO queue at any given time. |
int |
getJournalMinFiles()
Returns the number of journal files to pre-create. |
String |
getJournalType()
Returns the type of journal used by this server (either NIO or ASYNCIO ). |
String |
getLargeMessagesDirectory()
Returns the file system directory used to store large messages. |
String |
getManagementAddress()
Returns the management address of this server. |
String |
getManagementNotificationAddress()
Returns the management notification address of this server. |
int |
getMessageCounterMaxDayCount()
Returns the maximum number of days kept in memory for message counter. |
long |
getMessageCounterSamplePeriod()
Returns the sample period (in milliseconds) to take message counter snapshot. |
long |
getMessageExpiryScanPeriod()
Returns the frequency (in milliseconds) to scan messages to detect which messages have expired. |
long |
getMessageExpiryThreadPriority()
Returns the priority of the thread used to scan message expiration. |
String |
getPagingDirectory()
Returns the file system directory used to store paging files. |
String[] |
getQueueNames()
Returns the names of the queues created on this server. |
int |
getScheduledThreadPoolMaxSize()
Returns the maximum number of threads in the scheduled thread pool. |
long |
getSecurityInvalidationInterval()
Returns the interval time (in milliseconds) to invalidate security credentials. |
int |
getThreadPoolMaxSize()
Returns the maximum number of threads in the thread pool. |
long |
getTransactionTimeout()
Returns the timeout (in milliseconds) after which transactions is removed from the resource manager after it was created. |
long |
getTransactionTimeoutScanPeriod()
Returns the frequency (in milliseconds) to scan transactions to detect which transactions have timed out. |
String |
getVersion()
Returns this server's version. |
boolean |
isAsyncConnectionExecutionEnabled()
Returns whether code coming from connection is executed asynchronously or not. |
boolean |
isBackup()
Returns true if this server is a backup, false if it is a live server. |
boolean |
isClustered()
Returns whether this server is clustered. |
boolean |
isCreateBindingsDir()
Returns whether the bindings directory is created on this server startup. |
boolean |
isCreateJournalDir()
Returns whether the journal directory is created on this server startup. |
boolean |
isJournalSyncNonTransactional()
Returns whether the journal is synchronized when receiving non-transactional data. |
boolean |
isJournalSyncTransactional()
Returns whether the journal is synchronized when receiving transactional data. |
boolean |
isMessageCounterEnabled()
Returns whether message counter is enabled for this server. |
boolean |
isPersistDeliveryCountBeforeDelivery()
Returns whether delivery count is persisted before messages are delivered to the consumers. |
boolean |
isPersistenceEnabled()
Returns whether this server is using persistence and store data. |
boolean |
isPersistIDCache()
Returns whether message ID cache is persisted. |
boolean |
isSecurityEnabled()
Returns whether security is enabled for this server. |
boolean |
isSharedStore()
Returns whether this server shares its data store with a corresponding live or backup server. |
boolean |
isStarted()
Return whether this server is started. |
boolean |
isWildcardRoutingEnabled()
Returns whether wildcard routing is supported by this server. |
String[] |
listConnectionIDs()
Lists all the IDs of the connections connected to this server. |
String[] |
listHeuristicCommittedTransactions()
List transactions which have been heuristically committed. |
String[] |
listHeuristicRolledBackTransactions()
List transactions which have been heuristically rolled back. |
String[] |
listPreparedTransactions()
List all the prepared transaction, sorted by date, oldest first. |
String[] |
listRemoteAddresses()
Lists the addresses of all the clients connected to this address. |
String[] |
listRemoteAddresses(String ipAddress)
Lists the addresses of the clients connected to this address which matches the specified IP address. |
String[] |
listSessions(String connectionID)
Lists all the sessions IDs for the specified connection ID. |
void |
resetAllMessageCounterHistories()
Reset histories for all message counters. |
void |
resetAllMessageCounters()
Reset all message counters. |
boolean |
rollbackPreparedTransaction(String transactionAsBase64)
Heuristically rolls back a prepared transaction. |
void |
sendQueueInfoToQueue(String queueName,
String address)
This method is used by HornetQ clustering and must not be called by HornetQ clients. |
void |
setMessageCounterMaxDayCount(int count)
Sets the maximum number of days kept in memory for message counter. |
void |
setMessageCounterSamplePeriod(long newPeriod)
Sets the sample period to take message counter snapshot. |
Method Detail |
---|
String getBackupConnectorName()
null
.
String getVersion()
int getConnectionCount()
boolean isStarted()
String[] getInterceptorClassNames()
Interceptor
boolean isClustered()
int getScheduledThreadPoolMaxSize()
int getThreadPoolMaxSize()
long getSecurityInvalidationInterval()
boolean isSecurityEnabled()
String getBindingsDirectory()
String getJournalDirectory()
String getJournalType()
NIO
or ASYNCIO
).
boolean isJournalSyncTransactional()
boolean isJournalSyncNonTransactional()
int getJournalFileSize()
int getJournalMinFiles()
int getJournalMaxIO()
int getJournalBufferSize()
int getJournalBufferTimeout()
int getJournalCompactMinFiles()
int getJournalCompactPercentage()
boolean isPersistenceEnabled()
boolean isCreateBindingsDir()
boolean isCreateJournalDir()
boolean isMessageCounterEnabled()
int getMessageCounterMaxDayCount()
void setMessageCounterMaxDayCount(int count) throws Exception
count
- value must be greater than 0
Exception
long getMessageCounterSamplePeriod()
void setMessageCounterSamplePeriod(long newPeriod) throws Exception
newPeriod
- value must be greater than 1000ms
Exception
boolean isBackup()
true
if this server is a backup, false
if it is a live server.
false
.
boolean isSharedStore()
String getPagingDirectory()
boolean isPersistDeliveryCountBeforeDelivery()
long getConnectionTTLOverride()
String getManagementAddress()
String getManagementNotificationAddress()
int getIDCacheSize()
boolean isPersistIDCache()
String getLargeMessagesDirectory()
boolean isWildcardRoutingEnabled()
long getTransactionTimeout()
long getTransactionTimeoutScanPeriod()
long getMessageExpiryScanPeriod()
long getMessageExpiryThreadPriority()
boolean isAsyncConnectionExecutionEnabled()
Object[] getConnectors() throws Exception
Exception
String getConnectorsAsJSON() throws Exception
Exception
String[] getAddressNames()
String[] getQueueNames()
void createQueue(String address, String name) throws Exception
HornetQException.QUEUE_EXISTS
) exception if the queue already exits.
address
- address to bind the queue toname
- name of the queue
Exception
void createQueue(String address, String name, String filter, boolean durable) throws Exception
HornetQException.QUEUE_EXISTS
) exception if the queue already exits.
address
- address to bind the queue toname
- name of the queuefilter
- of the queuedurable
- whether the queue is durable
Exception
void createQueue(String address, String name, boolean durable) throws Exception
HornetQException.QUEUE_EXISTS
) exception if the queue already exits.
address
- address to bind the queue toname
- name of the queuedurable
- whether the queue is durable
Exception
void deployQueue(String address, String name, String filter) throws Exception
address
- address to bind the queue toname
- name of the queuefilter
- of the queue
Exception
void deployQueue(String address, String name, String filter, boolean durable) throws Exception
address
- address to bind the queue toname
- name of the queuefilter
- of the queuedurable
- whether the queue is durable
Exception
void destroyQueue(String name) throws Exception
Exception
void enableMessageCounters() throws Exception
Exception
void disableMessageCounters() throws Exception
Exception
void resetAllMessageCounters() throws Exception
Exception
void resetAllMessageCounterHistories() throws Exception
Exception
String[] listPreparedTransactions() throws Exception
Exception
commitPreparedTransaction(String)
,
rollbackPreparedTransaction(String)
String[] listHeuristicCommittedTransactions() throws Exception
Exception
String[] listHeuristicRolledBackTransactions() throws Exception
Exception
boolean commitPreparedTransaction(String transactionAsBase64) throws Exception
transactionAsBase64
- base 64 representation of a prepare transaction
true
if the transaction was successfully committed, false
else
Exception
listPreparedTransactions()
boolean rollbackPreparedTransaction(String transactionAsBase64) throws Exception
transactionAsBase64
- base 64 representation of a prepare transaction
true
if the transaction was successfully rolled back, false
else
Exception
listPreparedTransactions()
String[] listRemoteAddresses() throws Exception
Exception
String[] listRemoteAddresses(String ipAddress) throws Exception
Exception
boolean closeConnectionsForAddress(String ipAddress) throws Exception
Exception
String[] listConnectionIDs() throws Exception
Exception
String[] listSessions(String connectionID) throws Exception
Exception
void sendQueueInfoToQueue(String queueName, String address) throws Exception
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |