com.gemstone.gemfire.cache.asyncqueue
Interface AsyncEventQueueFactory

public interface AsyncEventQueueFactory

Factory to create the AsyncEventQueue.

Since:

7.0

Method Summary

AsyncEventQueue	create(String id, AsyncEventListener listener) Creates the AsyncEventQueue.
AsyncEventQueueFactory	setBatchSize(int size) Sets the batch size for an AsyncEventQueue's queue.
AsyncEventQueueFactory	setDiskStoreName(String name) Sets the disk store name for overflow or persistence.
AsyncEventQueueFactory	setMaximumQueueMemory(int memory) Sets the maximum amount of memory (in MB) for an AsyncEventQueue's queue.
AsyncEventQueueFactory	setParallel(boolean isParallel) Indicates whether all VMs need to distribute events to remote site.
AsyncEventQueueFactory	setPersistent(boolean isPersistent) Sets whether the AsyncEventQueue is persistent or not.

Method Detail

setDiskStoreName

AsyncEventQueueFactory setDiskStoreName(String name)

Sets the disk store name for overflow or persistence.

Parameters:

name -

setMaximumQueueMemory

AsyncEventQueueFactory setMaximumQueueMemory(int memory)

Sets the maximum amount of memory (in MB) for an AsyncEventQueue's queue.

Parameters:

memory - The maximum amount of memory (in MB) for an AsyncEventQueue's queue

setBatchSize

AsyncEventQueueFactory setBatchSize(int size)

Sets the batch size for an AsyncEventQueue's queue.

Parameters:

size - The size of batches sent to its AsyncEventListener

setPersistent

AsyncEventQueueFactory setPersistent(boolean isPersistent)

Sets whether the AsyncEventQueue is persistent or not.

Parameters:

isPersistent - Whether to enable persistence for an AsyncEventQueue.

setParallel

AsyncEventQueueFactory setParallel(boolean isParallel)

Indicates whether all VMs need to distribute events to remote site. In this case only the events originating in a particular VM will be in dispatched in order.

Parameters:

isParallel - boolean to indicate whether distribution policy is parallel

create

AsyncEventQueue create(String id,
                       AsyncEventListener listener)

Creates the AsyncEventQueue. It accepts Id of AsyncEventQueue and instance of AsyncEventListener. Multiple queues can be created using Same listener instance. So, the instance of AsyncEventListener should be thread safe in that case. The AsyncEventListener will start receiving events when the AsyncEventQueue is created.

Parameters:

id - Id of AsyncEventQueue

listener - AsyncEventListener to be added to the regions that are configured to use this queue.