org.rvpf.base.som

Class QueueInfo

Object

QueueInfo

All Implemented Interfaces:

Serializable

@ThreadSafe
public final class QueueInfo
extends Object
implements Serializable

Queue info.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
QueueInfo()

Method Summary

Modifier and Type	Method and Description
void	clearFilesSize() Clears files size info.
void	clearMessageCount() Clears message count info.
int	getFileCount() Gets the file count info.
long	getFilesSize() Gets files size info.
Optional<DateTime>	getLastReceiverCommit() Gets the last receiver commit time.
Optional<DateTime>	getLastSenderCommit() Gets the last sender commit time.
long	getMessageCount() Gets message count info.
long	getMessagesDropped() Gets messages dropped info.
Optional<DateTime>	getReceiverConnectTime() Gets the receiver connect time.
int	getSenderCount() Gets the sender count.
void	setLastReceiverCommit(DateTime lastReceiverCommit) Sets the last receiver commit time.
void	setLastSenderCommit(DateTime lastSenderCommit) Sets the last sender commit time.
void	setReceiverConnectTime(Optional<DateTime> receiverConnecTime) Sets the receiver connect time.
void	updateFileCount(int delta) Updates the file count.
void	updateFilesSize(long delta) Updates the files size.
void	updateMessageCount(long delta) Updates the message count.
void	updateMessagesDropped(long delta) Updates the count of messages dropped.
void	updateSenderCount(int delta) Updates the sender count.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueueInfo

public QueueInfo()

Method Detail

clearFilesSize

public void clearFilesSize()

Clears files size info.

clearMessageCount

public void clearMessageCount()

Clears message count info.

getFileCount

@Nonnegative
 @CheckReturnValue
public int getFileCount()

Gets the file count info.

Returns:

The file count info.

getFilesSize

@Nonnegative
 @CheckReturnValue
public long getFilesSize()

Gets files size info.

Returns:

The files size.

getLastReceiverCommit

@Nonnull
 @CheckReturnValue
public Optional<DateTime> getLastReceiverCommit()

Gets the last receiver commit time.

Returns:

The optional last receiver commit time.

getLastSenderCommit

@Nonnull
 @CheckReturnValue
public Optional<DateTime> getLastSenderCommit()

Gets the last sender commit time.

Returns:

The optional last sender commit time.

getMessageCount

@Nonnegative
 @CheckReturnValue
public long getMessageCount()

Gets message count info.

Returns:

The message count.

getMessagesDropped

@Nonnegative
 @CheckReturnValue
public long getMessagesDropped()

Gets messages dropped info.

Returns:

The messages dropped.

getReceiverConnectTime

@Nonnull
 @CheckReturnValue
public Optional<DateTime> getReceiverConnectTime()

Gets the receiver connect time.

Returns:

The optional receiver connect time.

getSenderCount

@Nonnegative
 @CheckReturnValue
public int getSenderCount()

Gets the sender count.

Returns:

The sender count.

setLastReceiverCommit

public void setLastReceiverCommit(@Nonnull
                                  DateTime lastReceiverCommit)

Sets the last receiver commit time.

Parameters:

lastReceiverCommit - The last receiver commit time.

setLastSenderCommit

public void setLastSenderCommit(@Nonnull
                                DateTime lastSenderCommit)

Sets the last sender commit time.

Parameters:

lastSenderCommit - The last sender commit time.

setReceiverConnectTime

public void setReceiverConnectTime(@Nonnull
                                   Optional<DateTime> receiverConnecTime)

Sets the receiver connect time.

Parameters:

receiverConnecTime - The optional receiver connect time.

updateFileCount

public void updateFileCount(int delta)

Updates the file count.

Parameters:

delta - The count delta.

updateFilesSize

public void updateFilesSize(long delta)

Updates the files size.

Parameters:

delta - The size delta.

updateMessageCount

public void updateMessageCount(long delta)

Updates the message count.

Parameters:

delta - The count delta.

updateMessagesDropped

public void updateMessagesDropped(long delta)

Updates the count of messages dropped.

Parameters:

delta - The count delta.

updateSenderCount

public void updateSenderCount(int delta)

Updates the sender count.

Parameters:

delta - The count delta.