public class EndpointView extends Object implements EndpointViewMBean, org.apache.axis2.transport.base.MessageLevelMetricsCollector
Constructor and Description |
---|
EndpointView(String endpointName,
Endpoint endpoint)
Create a new MBean to manage the given endpoint
|
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
int |
getActiveChildren()
Return the number of active children for this endpoint
|
double |
getAvgSizeReceived() |
double |
getAvgSizeSent() |
long |
getBytesReceived()
Number of bytes received, receiving replies
|
long |
getBytesSent()
Number of bytes sent
|
int |
getConsecutiveEndpointSuspensions() |
int |
getConsecutiveEndpointTimeouts() |
long |
getFaultsReceiving()
Number of faults, receiving replies
|
long |
getFaultsSending()
Number of faults sending
|
int |
getLast15MinuteEndpointSuspensions() |
int |
getLast15MinuteEndpointTimeouts() |
int |
getLast5MinuteEndpointSuspensions() |
int |
getLast5MinuteEndpointTimeouts() |
int |
getLastMinuteEndpointSuspensions() |
int |
getLastMinuteEndpointTimeouts() |
long |
getLastResetTime()
Time when statistics was last reset for this leaf endpoint
|
long |
getMaxSizeReceived() |
long |
getMaxSizeSent() |
long |
getMessagesReceived()
Number of messages (ie replies) received
|
long |
getMessagesSent()
Number of messages sent
|
long |
getMetricsWindow()
Time since statistics was last reset for this leaf endpoint
|
long |
getMinSizeReceived() |
long |
getMinSizeSent() |
int |
getReadyChildren()
Return the number of ready children for this endpoint
|
Map<Integer,Long> |
getReceivingFaultTable()
A Map of receive faults with the error code and count
|
Map<Integer,Long> |
getResponseCodeTable()
A Map of response codes and counts
|
Map<Integer,Long> |
getSendingFaultTable()
A Map of send faults with the error code and count
|
Date |
getSuspendedAt() |
Date |
getTimedoutAt() |
long |
getTimeoutsReceiving()
Number of timeouts, receiving replies
|
long |
getTimeoutsSending()
Number of timeouts, sending
|
int |
getTotalChildren()
Return number of children for this endpoint
|
int |
getTotalEndpointSuspensions() |
int |
getTotalEndpointTimeouts() |
void |
incrementBytesReceived(long size) |
void |
incrementBytesSent(long size) |
void |
incrementFaultsReceiving(int errorCode) |
void |
incrementFaultsSending(int errorCode) |
void |
incrementMessagesReceived() |
void |
incrementMessagesSent() |
void |
incrementSuspensions() |
void |
incrementTimeouts() |
void |
incrementTimeoutsReceiving() |
void |
incrementTimeoutsSending() |
boolean |
isActive()
Is a leaf level endpoint active? For a group endpoint this means at least one is active
|
boolean |
isEndpointInState(int state)
Is the endpoint considered to be in the given state?
|
boolean |
isSuspended()
Is this leaf level endpoint in suspend state?
|
boolean |
isSwitchedOff()
Is this leaf level endpoint switched off?
|
boolean |
isTimedout()
Is this leaf level endpoint in timeout state? For a group, has all endpoints timed out?
|
void |
notifyReceivedMessageSize(long size) |
void |
notifySentMessageSize(long size) |
void |
reportReceivingFault(int errorCode)
Report a/an [typically non-fatal] error to the receiving fault table, without incrementing
the receivingFault count
|
void |
reportResponseCode(int respCode)
Collect response code statistics
|
void |
reportSendingFault(int errorCode)
Report a/an [typically non-fatal] error to the sending fault table, without incrementing
the sendingFault count e.g.
|
void |
resetConsecutiveSuspensions() |
void |
resetConsecutiveTimeouts() |
void |
resetStatistics() |
void |
setSuspendedAt(Date suspendedAt) |
void |
setTimedoutAt(Date timedoutAt) |
void |
switchOff()
Switch off a leaf endpoint, or all endpoints of a group - for maintenance
|
void |
switchOn()
Switch on a leaf endpoint, or all endpoints on a group - from maintenance
|
public void destroy()
public void switchOn() throws Exception
switchOn
in interface EndpointViewMBean
Exception
public void switchOff() throws Exception
switchOff
in interface EndpointViewMBean
Exception
public boolean isActive() throws Exception
isActive
in interface EndpointViewMBean
Exception
public boolean isTimedout() throws Exception
isTimedout
in interface EndpointViewMBean
Exception
public boolean isSuspended() throws Exception
isSuspended
in interface EndpointViewMBean
Exception
public boolean isSwitchedOff() throws Exception
isSwitchedOff
in interface EndpointViewMBean
Exception
public int getTotalChildren() throws Exception
getTotalChildren
in interface EndpointViewMBean
Exception
public int getActiveChildren() throws Exception
getActiveChildren
in interface EndpointViewMBean
Exception
public int getReadyChildren() throws Exception
getReadyChildren
in interface EndpointViewMBean
Exception
public long getLastResetTime()
getLastResetTime
in interface EndpointViewMBean
public long getMetricsWindow()
getMetricsWindow
in interface EndpointViewMBean
public Map<Integer,Long> getReceivingFaultTable()
getReceivingFaultTable
in interface EndpointViewMBean
public Map<Integer,Long> getSendingFaultTable()
getSendingFaultTable
in interface EndpointViewMBean
public Map<Integer,Long> getResponseCodeTable()
getResponseCodeTable
in interface EndpointViewMBean
public Date getSuspendedAt()
getSuspendedAt
in interface EndpointViewMBean
public void setSuspendedAt(Date suspendedAt)
public Date getTimedoutAt()
getTimedoutAt
in interface EndpointViewMBean
public void setTimedoutAt(Date timedoutAt)
public int getConsecutiveEndpointSuspensions()
getConsecutiveEndpointSuspensions
in interface EndpointViewMBean
public void incrementSuspensions()
public void resetConsecutiveSuspensions()
public int getConsecutiveEndpointTimeouts()
getConsecutiveEndpointTimeouts
in interface EndpointViewMBean
public void incrementTimeouts()
public void resetConsecutiveTimeouts()
public int getTotalEndpointSuspensions()
getTotalEndpointSuspensions
in interface EndpointViewMBean
public int getTotalEndpointTimeouts()
getTotalEndpointTimeouts
in interface EndpointViewMBean
public int getLastMinuteEndpointSuspensions()
getLastMinuteEndpointSuspensions
in interface EndpointViewMBean
public int getLast5MinuteEndpointSuspensions()
getLast5MinuteEndpointSuspensions
in interface EndpointViewMBean
public int getLast15MinuteEndpointSuspensions()
getLast15MinuteEndpointSuspensions
in interface EndpointViewMBean
public int getLastMinuteEndpointTimeouts()
getLastMinuteEndpointTimeouts
in interface EndpointViewMBean
public int getLast5MinuteEndpointTimeouts()
getLast5MinuteEndpointTimeouts
in interface EndpointViewMBean
public int getLast15MinuteEndpointTimeouts()
getLast15MinuteEndpointTimeouts
in interface EndpointViewMBean
public long getMessagesReceived()
getMessagesReceived
in interface EndpointViewMBean
public long getFaultsReceiving()
getFaultsReceiving
in interface EndpointViewMBean
public long getTimeoutsReceiving()
getTimeoutsReceiving
in interface EndpointViewMBean
public long getBytesReceived()
getBytesReceived
in interface EndpointViewMBean
public long getMessagesSent()
getMessagesSent
in interface EndpointViewMBean
public long getFaultsSending()
getFaultsSending
in interface EndpointViewMBean
public long getTimeoutsSending()
getTimeoutsSending
in interface EndpointViewMBean
public long getBytesSent()
getBytesSent
in interface EndpointViewMBean
public long getMinSizeReceived()
getMinSizeReceived
in interface EndpointViewMBean
public long getMaxSizeReceived()
getMaxSizeReceived
in interface EndpointViewMBean
public long getMinSizeSent()
getMinSizeSent
in interface EndpointViewMBean
public long getMaxSizeSent()
getMaxSizeSent
in interface EndpointViewMBean
public double getAvgSizeReceived()
getAvgSizeReceived
in interface EndpointViewMBean
public double getAvgSizeSent()
getAvgSizeSent
in interface EndpointViewMBean
public void resetStatistics()
resetStatistics
in interface EndpointViewMBean
public void incrementMessagesReceived()
incrementMessagesReceived
in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector
public void incrementFaultsReceiving(int errorCode)
incrementFaultsReceiving
in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector
public void incrementTimeoutsReceiving()
incrementTimeoutsReceiving
in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector
public void incrementBytesReceived(long size)
incrementBytesReceived
in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector
public void incrementMessagesSent()
incrementMessagesSent
in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector
public void incrementFaultsSending(int errorCode)
incrementFaultsSending
in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector
public void incrementTimeoutsSending()
incrementTimeoutsSending
in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector
public void incrementBytesSent(long size)
incrementBytesSent
in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector
public void notifyReceivedMessageSize(long size)
notifyReceivedMessageSize
in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector
public void notifySentMessageSize(long size)
notifySentMessageSize
in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector
public void reportSendingFault(int errorCode)
reportSendingFault
in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector
errorCode
- the code to reportpublic void reportReceivingFault(int errorCode)
reportReceivingFault
in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector
errorCode
- the code to reportpublic void reportResponseCode(int respCode)
reportResponseCode
in interface org.apache.axis2.transport.base.MessageLevelMetricsCollector
respCode
- response codepublic boolean isEndpointInState(int state)
state
- the state to considerCopyright © 2005-2017 Apache Software Foundation. All Rights Reserved.