net.bluemind.core.backup.continuous.tests

Class UserDefaultAliasTests.ApplyWatch

java.lang.Object

net.bluemind.core.backup.continuous.tests.UserDefaultAliasTests.ApplyWatch

All Implemented Interfaces:

IReplicationObserver, IReplicationObserverProvider

Enclosing class:

UserDefaultAliasTests

public static class UserDefaultAliasTests.ApplyWatch
extends java.lang.Object
implements IReplicationObserverProvider, IReplicationObserver

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.Map<java.lang.String,java.util.concurrent.atomic.AtomicLong>	counts

Constructor Summary

Constructors

Constructor and Description
ApplyWatch()

Method Summary

Modifier and Type	Method and Description
static long	count(java.lang.String mboxUniqueId)
IReplicationObserver	create(io.vertx.core.Vertx vertx)
void	onApplyMailbox(java.lang.String mboxUniqueId, long lastUid)
void	onApplyMessages(int total)

Methods inherited from class java.lang.Object

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

Field Detail

counts

public static final java.util.Map<java.lang.String,java.util.concurrent.atomic.AtomicLong> counts

Constructor Detail

ApplyWatch

public ApplyWatch()

Method Detail

create

public IReplicationObserver create(io.vertx.core.Vertx vertx)

Specified by:

create in interface IReplicationObserverProvider

onApplyMessages

public void onApplyMessages(int total)

Specified by:

onApplyMessages in interface IReplicationObserver

count

public static long count(java.lang.String mboxUniqueId)

onApplyMailbox

public void onApplyMailbox(java.lang.String mboxUniqueId,
                           long lastUid)

Specified by:

onApplyMailbox in interface IReplicationObserver