com.continuent.tungsten.replicator.storage.parallel
Class ParallelQueueStore.QueueMetadataImpl

java.lang.Object
  com.continuent.tungsten.replicator.storage.parallel.ParallelQueueStore.QueueMetadataImpl

All Implemented Interfaces:

PartitionMetadata

Enclosing class:

ParallelQueueStore

public class ParallelQueueStore.QueueMetadataImpl
extends java.lang.Object
implements PartitionMetadata

Method Summary

long	getCurrentSize() Returns the number of events currently in the partition.
int	getPartitionNumber() Returns the number of the partition to which the metadata applies.

Methods inherited from class java.lang.Object

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

Method Detail

getPartitionNumber

public int getPartitionNumber()

Description copied from interface: PartitionMetadata

Returns the number of the partition to which the metadata applies.

Specified by:

getPartitionNumber in interface PartitionMetadata

getCurrentSize

public long getCurrentSize()

Description copied from interface: PartitionMetadata

Returns the number of events currently in the partition. The implementation must be non-blocking and thread-safe. This number may be an estimate.

Specified by:

getCurrentSize in interface PartitionMetadata