public class ConnectionMBean extends AMQManagedObject implements ManagedConnection
CHAN_ID, COMPOSITE_ITEM_NAMES_DESC, DEFAULT_QUEUE, FLOW_BLOCKED, TABULAR_UNIQUE_INDEX, TRANSACTIONAL, TYPE, UNACKED_COUNT
DOMAIN
Constructor and Description |
---|
ConnectionMBean(Connection conn,
VirtualHostMBean virtualHostMBean) |
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() |
protected long |
getBytesIn() |
protected long |
getBytesOut() |
String |
getClientId() |
protected T |
getConfiguredObject() |
double |
getDataDeliveryRate() |
double |
getDataReceiptRate() |
Date |
getLastIoTime()
Tells the last time, the IO operation was done.
|
Long |
getMaximumNumberOfChannels()
Threshold high value for no of channels.
|
double |
getMessageDeliveryRate() |
double |
getMessageReceiptRate() |
protected long |
getMessagesIn() |
protected long |
getMessagesOut() |
String |
getObjectInstanceName() |
ManagedObject |
getParentObject() |
double |
getPeakDataDeliveryRate() |
double |
getPeakDataReceiptRate() |
double |
getPeakMessageDeliveryRate() |
double |
getPeakMessageReceiptRate() |
String |
getRemoteAddress()
Tells the remote address of this connection.
|
long |
getTotalDataDelivered() |
long |
getTotalDataReceived() |
long |
getTotalMessagesDelivered() |
long |
getTotalMessagesReceived() |
String |
getVersion() |
protected void |
initStats() |
boolean |
isStatisticsEnabled()
Is statistics collection enabled for this connection.
|
void |
resetStatistics() |
void |
rollbackTransactions(int channelId)
Rollsback the transactions if the channel is transactional.
|
void |
setStatisticsEnabled(boolean enabled)
Sets statistics collection enabled/disabled for this connection.
|
protected void |
updateStats() |
addNotificationListener, getBroadcaster, incrementAndGetSequenceNumber, removeNotificationListener
getHierarchicalName, getHierarchicalType, getManagementInterface, getMBeanInfo, getNotificationInfo, getObjectName, 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
getDataDeliveryRate, getDataReceiptRate, getMessageDeliveryRate, getMessageReceiptRate, getPeakDataDeliveryRate, getPeakDataReceiptRate, getPeakMessageDeliveryRate, getPeakMessageReceiptRate, getTotalDataDelivered, getTotalDataReceived, getTotalMessagesDelivered, getTotalMessagesReceived, resetStatistics
getNotificationInfo
public ConnectionMBean(Connection conn, VirtualHostMBean virtualHostMBean) throws JMException
JMException
protected long getBytesOut()
protected long getBytesIn()
protected long getMessagesOut()
protected long getMessagesIn()
public String getObjectInstanceName()
getObjectInstanceName
in interface ManagedObject
public ManagedObject getParentObject()
getParentObject
in interface ManagedObject
getParentObject
in class DefaultManagedObject
public String getClientId()
getClientId
in interface ManagedConnection
public String getAuthorizedId()
getAuthorizedId
in interface ManagedConnection
public String getVersion()
getVersion
in interface ManagedConnection
public String getRemoteAddress()
ManagedConnection
getRemoteAddress
in interface ManagedConnection
public Date getLastIoTime()
ManagedConnection
getLastIoTime
in interface ManagedConnection
public Long getMaximumNumberOfChannels()
ManagedConnection
getMaximumNumberOfChannels
in interface ManagedConnection
public TabularData channels() throws IOException, JMException
ManagedConnection
channels
in interface ManagedConnection
IOException
JMException
public void commitTransactions(int channelId) throws JMException
ManagedConnection
commitTransactions
in interface ManagedConnection
JMException
public void rollbackTransactions(int channelId) throws JMException
ManagedConnection
rollbackTransactions
in interface ManagedConnection
JMException
public void closeConnection() throws Exception
ManagedConnection
closeConnection
in interface ManagedConnection
Exception
public boolean isStatisticsEnabled()
ManagedConnection
isStatisticsEnabled
in interface ManagedConnection
public void setStatisticsEnabled(boolean enabled)
ManagedConnection
setStatisticsEnabled
in interface ManagedConnection
protected void initStats()
protected void updateStats()
public double getPeakMessageDeliveryRate()
public double getPeakDataDeliveryRate()
public double getMessageDeliveryRate()
public double getDataDeliveryRate()
public long getTotalMessagesDelivered()
public long getTotalDataDelivered()
protected final T getConfiguredObject()
public double getPeakMessageReceiptRate()
public double getPeakDataReceiptRate()
public double getMessageReceiptRate()
public double getDataReceiptRate()
public long getTotalMessagesReceived()
public long getTotalDataReceived()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.