GemFire 7.0.1

com.gemstone.gemfire.cache.asyncqueue
Interface AsyncEventQueue


public interface AsyncEventQueue

Interface of AsyncEventQueue. This represents the channel over which the events are delivered to the AsyncEventListener.

Since:
7.0

Method Summary
 AsyncEventListener getAsyncEventListener()
          The AsyncEventListener that is attached to the queue.
 int getBatchSize()
          Represents the size of a batch that gets delivered over the AsyncEventQueue
 int getBatchTimeInterval()
          Represents the maximum time interval that can elapse before a batch is sent from AsyncEventQueue
 String getDiskStoreName()
          The Disk store that is required for overflow and persistence
 int getDispatcherThreads()
          Returns the number of dispatcher threads working for this AsyncEventQueue
 String getId()
           
 int getMaximumQueueMemory()
          The maximum memory after which the data needs to be overflowed to disk
 Gateway.OrderPolicy getOrderPolicy()
          Returns the order policy followed while dispatching the events to AsyncEventListener.
 boolean isBatchConflationEnabled()
          Represents whether batch conflation is enabled for batches sent from AsyncEventQueue
 boolean isDiskSynchronous()
          Represents whether writing to disk is synchronous or not.
 boolean isParallel()
          Represents whether this queue is parallel (higher throughput) or serial.
 boolean isPersistent()
          Represents whether the AsyncEventQueue is configured to be persistent or non-persistent
 boolean isPrimary()
          Represents whether the queue is primary or secondary.
 

Method Detail

getId

String getId()
Returns:
String Id of the AsyncEventQueue

getDiskStoreName

String getDiskStoreName()
The Disk store that is required for overflow and persistence

Returns:
String

getMaximumQueueMemory

int getMaximumQueueMemory()
The maximum memory after which the data needs to be overflowed to disk

Returns:
int

getBatchSize

int getBatchSize()
Represents the size of a batch that gets delivered over the AsyncEventQueue

Returns:
int

getBatchTimeInterval

int getBatchTimeInterval()
Represents the maximum time interval that can elapse before a batch is sent from AsyncEventQueue

Returns:
int

isBatchConflationEnabled

boolean isBatchConflationEnabled()
Represents whether batch conflation is enabled for batches sent from AsyncEventQueue

Returns:
boolean

isPersistent

boolean isPersistent()
Represents whether the AsyncEventQueue is configured to be persistent or non-persistent

Returns:
boolean

isDiskSynchronous

boolean isDiskSynchronous()
Represents whether writing to disk is synchronous or not.

Returns:
boolean

isPrimary

boolean isPrimary()
Represents whether the queue is primary or secondary. Events get delivered only by the primary queue. If the primary queue goes down then the secondary queue first becomes primary and then starts delivering the events.

Returns:
boolean

getAsyncEventListener

AsyncEventListener getAsyncEventListener()
The AsyncEventListener that is attached to the queue. All the event passing over the queue are delivered to attached listener.

Returns:
AsyncEventListener Implementation of AsyncEventListener

isParallel

boolean isParallel()
Represents whether this queue is parallel (higher throughput) or serial.

Returns:
boolean True if the queue is parallel, false otherwise.

getDispatcherThreads

int getDispatcherThreads()
Returns the number of dispatcher threads working for this AsyncEventQueue

Returns:
the number of dispatcher threads working for this AsyncEventQueue

getOrderPolicy

Gateway.OrderPolicy getOrderPolicy()
Returns the order policy followed while dispatching the events to AsyncEventListener. Order policy is set only when dispatcher threads are > 1

Returns:
the order policy followed while dispatching the events to AsyncEventListener.

GemFire 7.0.1

Copyright © 1997-2013 VMware, Inc. All rights reserved.