ServerConnectionStatistics
instead.@Deprecated @ManagedObject(value="Connector Statistics") public class ConnectorStatistics extends AbstractLifeCycle implements Dumpable, Connection.Listener
ContainerLifeCycle.addBean(Object)
will register the listener with all connections accepted by that connector.Modifier and Type | Class and Description |
---|---|
private static class |
ConnectorStatistics.Sample
Deprecated.
|
AbstractLifeCycle.AbstractLifeCycleListener
Connection.Listener.Adapter
LifeCycle.Listener
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.atomic.LongAdder |
_closedIn
Deprecated.
|
private java.util.concurrent.atomic.LongAdder |
_closedOut
Deprecated.
|
private SampleStatistic |
_connectionDurationStats
Deprecated.
|
private CounterStatistic |
_connectionStats
Deprecated.
|
private SampleStatistic |
_messagesIn
Deprecated.
|
private int |
_messagesInPerSecond
Deprecated.
|
private SampleStatistic |
_messagesOut
Deprecated.
|
private int |
_messagesOutPerSecond
Deprecated.
|
private java.util.concurrent.atomic.AtomicLong |
_nanoStamp
Deprecated.
|
private java.util.concurrent.ConcurrentMap<Connection,ConnectorStatistics.Sample> |
_samples
Deprecated.
|
private java.util.concurrent.atomic.AtomicLong |
_startMillis
Deprecated.
|
private static long |
SECOND_NANOS
Deprecated.
|
private static ConnectorStatistics.Sample |
ZERO
Deprecated.
|
FAILED, RUNNING, STARTED, STARTING, STOP_ON_FAILURE, STOPPED, STOPPING
Constructor and Description |
---|
ConnectorStatistics()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static void |
addToAllConnectors(Server server)
Deprecated.
|
void |
doStart()
Deprecated.
|
void |
doStop()
Deprecated.
|
java.lang.String |
dump()
Deprecated.
|
void |
dump(java.lang.Appendable out,
java.lang.String indent)
Deprecated.
|
int |
getBytesIn()
Deprecated.
|
int |
getBytesOut()
Deprecated.
|
long |
getConnectionDurationMax()
Deprecated.
|
double |
getConnectionDurationMean()
Deprecated.
|
double |
getConnectionDurationStdDev()
Deprecated.
|
int |
getConnections()
Deprecated.
|
int |
getConnectionsOpen()
Deprecated.
|
int |
getConnectionsOpenMax()
Deprecated.
|
int |
getMessagesIn()
Deprecated.
|
int |
getMessagesInPerConnectionMax()
Deprecated.
|
double |
getMessagesInPerConnectionMean()
Deprecated.
|
double |
getMessagesInPerConnectionStdDev()
Deprecated.
|
int |
getMessagesInPerSecond()
Deprecated.
|
int |
getMessagesOut()
Deprecated.
|
int |
getMessagesOutPerConnectionMax()
Deprecated.
|
double |
getMessagesOutPerConnectionMean()
Deprecated.
|
double |
getMessagesOutPerConnectionStdDev()
Deprecated.
|
int |
getMessagesOutPerSecond()
Deprecated.
|
long |
getStartedMillis()
Deprecated.
|
void |
onClosed(Connection connection)
Deprecated.
|
void |
onOpened(Connection connection)
Deprecated.
|
void |
reset()
Deprecated.
|
private void |
update()
Deprecated.
|
addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, setStopTimeout, start, stop
private static final ConnectorStatistics.Sample ZERO
private final java.util.concurrent.atomic.AtomicLong _startMillis
private final CounterStatistic _connectionStats
private final SampleStatistic _messagesIn
private final SampleStatistic _messagesOut
private final SampleStatistic _connectionDurationStats
private final java.util.concurrent.ConcurrentMap<Connection,ConnectorStatistics.Sample> _samples
private final java.util.concurrent.atomic.LongAdder _closedIn
private final java.util.concurrent.atomic.LongAdder _closedOut
private java.util.concurrent.atomic.AtomicLong _nanoStamp
private volatile int _messagesInPerSecond
private volatile int _messagesOutPerSecond
private static final long SECOND_NANOS
public void onOpened(Connection connection)
onOpened
in interface Connection.Listener
public void onClosed(Connection connection)
onClosed
in interface Connection.Listener
@ManagedAttribute(value="Total number of bytes received by this connector") public int getBytesIn()
@ManagedAttribute(value="Total number of bytes sent by this connector") public int getBytesOut()
@ManagedAttribute(value="Total number of connections seen by this connector") public int getConnections()
@ManagedAttribute(value="Connection duration maximum in ms") public long getConnectionDurationMax()
@ManagedAttribute(value="Connection duration mean in ms") public double getConnectionDurationMean()
@ManagedAttribute(value="Connection duration standard deviation") public double getConnectionDurationStdDev()
@ManagedAttribute(value="Messages In for all connections") public int getMessagesIn()
@ManagedAttribute(value="Messages In per connection maximum") public int getMessagesInPerConnectionMax()
@ManagedAttribute(value="Messages In per connection mean") public double getMessagesInPerConnectionMean()
@ManagedAttribute(value="Messages In per connection standard deviation") public double getMessagesInPerConnectionStdDev()
@ManagedAttribute(value="Connections open") public int getConnectionsOpen()
@ManagedAttribute(value="Connections open maximum") public int getConnectionsOpenMax()
@ManagedAttribute(value="Messages Out for all connections") public int getMessagesOut()
@ManagedAttribute(value="Messages In per connection maximum") public int getMessagesOutPerConnectionMax()
@ManagedAttribute(value="Messages In per connection mean") public double getMessagesOutPerConnectionMean()
@ManagedAttribute(value="Messages In per connection standard deviation") public double getMessagesOutPerConnectionStdDev()
@ManagedAttribute(value="Connection statistics started ms since epoch") public long getStartedMillis()
@ManagedAttribute(value="Messages in per second calculated over period since last called") public int getMessagesInPerSecond()
@ManagedAttribute(value="Messages out per second calculated over period since last called") public int getMessagesOutPerSecond()
public void doStart()
doStart
in class AbstractLifeCycle
public void doStop()
doStop
in class AbstractLifeCycle
@ManagedOperation(value="Reset the statistics") public void reset()
@ManagedOperation(value="dump thread state") public java.lang.String dump()
public void dump(java.lang.Appendable out, java.lang.String indent) throws java.io.IOException
public static void addToAllConnectors(Server server)
private void update()