clientAPI

Class Client.SubscriberListener

java.lang.Object

cacheRunner.LoggingCacheCallback

cacheRunner.LoggingCacheListener

clientAPI.Client.SubscriberListener

All Implemented Interfaces:

com.gemstone.gemfire.cache.CacheCallback, com.gemstone.gemfire.cache.CacheListener, com.gemstone.gemfire.cache.Declarable

Enclosing class:

Client

public static class Client.SubscriberListener
extends LoggingCacheListener

A listener that is used in the subscriber client to wait for the publisher to finish its work.

Constructor Summary

Constructors

Constructor and Description
Client.SubscriberListener()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterCreate(com.gemstone.gemfire.cache.EntryEvent event) Counts the number of puts done by create events.
void	afterUpdate(com.gemstone.gemfire.cache.EntryEvent event) Counts the number of puts done by update events.
void	waitForPuts(int numToWaitFor) Blocks until numToWaitFor puts have been done.

Methods inherited from class cacheRunner.LoggingCacheListener

afterDestroy, afterInvalidate, afterRegionClear, afterRegionCreate, afterRegionDestroy, afterRegionInvalidate, afterRegionLive

Methods inherited from class cacheRunner.LoggingCacheCallback

close, format, format, init, log, log, log, log

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gemstone.gemfire.cache.CacheCallback

close

Constructor Detail

Client.SubscriberListener

public Client.SubscriberListener()

Method Detail

afterCreate

public void afterCreate(com.gemstone.gemfire.cache.EntryEvent event)

Counts the number of puts done by create events.

Specified by:

afterCreate in interface com.gemstone.gemfire.cache.CacheListener

Overrides:

afterCreate in class LoggingCacheListener

afterUpdate

public void afterUpdate(com.gemstone.gemfire.cache.EntryEvent event)

Counts the number of puts done by update events.

Specified by:

afterUpdate in interface com.gemstone.gemfire.cache.CacheListener

Overrides:

afterUpdate in class LoggingCacheListener

waitForPuts

public void waitForPuts(int numToWaitFor)
                 throws InterruptedException

Blocks until numToWaitFor puts have been done.

Throws:

InterruptedException