public interface ManagedConnection
Modifier and Type | Field and Description |
---|---|
static String |
CHAN_ID |
static List<String> |
COMPOSITE_ITEM_NAMES_DESC |
static String |
DEFAULT_QUEUE |
static String |
FLOW_BLOCKED |
static List<String> |
TABULAR_UNIQUE_INDEX |
static String |
TRANSACTIONAL |
static String |
TYPE |
static String |
UNACKED_COUNT |
Modifier and Type | Method and Description |
---|---|
TabularData |
channels()
channel details of all the channels opened for this connection.
|
void |
closeConnection()
Closes all the related channels and unregisters this connection from managed objects.
|
void |
commitTransactions(int channelId)
Commits the transactions if the channel is transactional.
|
String |
getAuthorizedId() |
String |
getClientId() |
double |
getDataDeliveryRate()
Rate of bytes delivered per second for the virtual host.
|
double |
getDataReceiptRate()
Rate of bytes received per second for this connection.
|
Date |
getLastIoTime()
Tells the last time, the IO operation was done.
|
Long |
getMaximumNumberOfChannels()
Threshold high value for no of channels.
|
double |
getMessageDeliveryRate()
Rate of messages delivered per second for the virtual host.
|
double |
getMessageReceiptRate()
Rate of messages received per second for this connection.
|
double |
getPeakDataDeliveryRate()
Peak rate of bytes delivered per second for the virtual host.
|
double |
getPeakDataReceiptRate()
Peak rate of bytes received per second for this connection.
|
double |
getPeakMessageDeliveryRate()
Peak rate of messages delivered per second for the virtual host.
|
double |
getPeakMessageReceiptRate()
Peak rate of messages received per second for this connection.
|
String |
getRemoteAddress()
Tells the remote address of this connection.
|
long |
getTotalDataDelivered()
Total count of bytes for the virtual host.
|
long |
getTotalDataReceived()
Total count of bytes received for this connection.
|
long |
getTotalMessagesDelivered()
Total count of messages delivered for the virtual host.
|
long |
getTotalMessagesReceived()
Total count of messages received for this connection.
|
String |
getVersion() |
boolean |
isStatisticsEnabled()
Is statistics collection enabled for this connection.
|
void |
resetStatistics()
Resets message and data statistics for this connection.
|
void |
rollbackTransactions(int channelId)
Rollsback the transactions if the channel is transactional.
|
void |
setStatisticsEnabled(boolean enabled)
Sets statistics collection enabled/disabled for this connection.
|
static final String TYPE
static final String CHAN_ID
static final String TRANSACTIONAL
static final String DEFAULT_QUEUE
static final String UNACKED_COUNT
static final String FLOW_BLOCKED
String getClientId()
String getAuthorizedId()
String getVersion()
String getRemoteAddress()
Date getLastIoTime()
Long getMaximumNumberOfChannels()
TabularData channels() throws IOException, JMException
IOException
JMException
void commitTransactions(int channelId) throws JMException
channelId
- JMException
void rollbackTransactions(int channelId) throws JMException
channelId
- JMException
void closeConnection() throws Exception
Exception
void resetStatistics() throws Exception
Exception
double getPeakMessageDeliveryRate()
double getPeakDataDeliveryRate()
double getMessageDeliveryRate()
double getDataDeliveryRate()
long getTotalMessagesDelivered()
long getTotalDataDelivered()
double getPeakMessageReceiptRate()
double getPeakDataReceiptRate()
double getMessageReceiptRate()
double getDataReceiptRate()
long getTotalMessagesReceived()
long getTotalDataReceived()
boolean isStatisticsEnabled()
void setStatisticsEnabled(boolean enabled)
enabled
- Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.