net.sf.xenqtt.client
Interface MessageStats

public interface MessageStats

Statistics for the MQTT client

Method Summary

double	getAverageAckLatencyMillis()
long	getDuplicateMessagesReceived()
long	getMaxAckLatencyMillis()
long	getMessagesInFlight()
long	getMessagesQueuedToSend()
long	getMessagesReceived()
long	getMessagesResent()
long	getMessagesSent()
long	getMinAckLatencyMillis()

Method Detail

getMessagesQueuedToSend

long getMessagesQueuedToSend()

Returns:

The number of messages queued to send. These messages are waiting to be sent. This stat cannot be reset

getMessagesInFlight

long getMessagesInFlight()

Returns:

The number of messages currently in-flight. An in-flight message is a message with a QOS other than QoS.AT_MOST_ONCE that has been sent to the broker but that has not been acked by the broker. This stat cannot be reset

getMessagesSent

long getMessagesSent()

Returns:

The number of messages that have been sent to the broker. This does not include the resent messages. This stat can be reset

getMessagesResent

long getMessagesResent()

Returns:

The number of messages that have been resent. This happens when an ack is not received from the broker in a timely manner. This stat can be reset

getMessagesReceived

long getMessagesReceived()

Returns:

The number of messages that have been received from the broker. This does not include the duplicate messages received. This stat can be reset

getDuplicateMessagesReceived

long getDuplicateMessagesReceived()

Returns:

The number of duplicate messages that have been received. This stat can be reset

getMinAckLatencyMillis

long getMinAckLatencyMillis()

Returns:

Minimum milliseconds it takes to receive and ack from the broker for QoS.AT_LEAST_ONCE (not supported by the client). This stat can be reset

getMaxAckLatencyMillis

long getMaxAckLatencyMillis()

Returns:

Max milliseconds it takes to receive and ack from the broker for QoS.AT_LEAST_ONCE (not supported by the client ). This stat can be reset

getAverageAckLatencyMillis

double getAverageAckLatencyMillis()

Returns:

Average milliseconds it takes to receive and ack from the broker for QoS.AT_LEAST_ONCE (not supported by the client). This stat can be reset