org.gridgain.grid.dr.hub.sender.store.memory

Class GridDrSenderHubInMemoryStore

java.lang.Object

org.gridgain.grid.dr.hub.sender.store.memory.GridDrSenderHubInMemoryStore

All Implemented Interfaces:

GridDrSenderHubStore, GridLifecycleAware

public class GridDrSenderHubInMemoryStore
extends Object
implements GridDrSenderHubStore, GridLifecycleAware

Data center replication sender hub store implementation which stores data in memory.

Configuration

Mandatory

There are no mandatory configuration parameters.

Optional

The following configuration parameters are optional:

• Maximum number of entries can be stored (see setMaxSize(int))
• Overflow mode defining how store will behave in case of overflow (see setOverflowMode(GridDrSenderHubStoreOverflowMode))

Java Example

 GridDrSenderHubConfiguration cfg = new GridDrSenderHubConfiguration();

 GridDrSenderHubInMemoryStore store = new GridDrSenderHubInMemoryStore();

 // Override default overflow mode.
 store.setOverflowMode(GridDrSenderHubStoreOverflowMode.REMOVE_OLDEST);

 // Set in-memory store for sender hub.
 cfg.setStore(store);
 

Spring Example

GridDrSenderHubInMemoryStore can be configured from Spring XML configuration file:

 <bean id="grid.custom.cfg" class="org.gridgain.grid.GridConfiguration" singleton="true">
         ...
         <property name="drSenderHubConfiguration">
              <bean class="org.gridgain.grid.dr.hub.sender.GridDrSenderHubConfiguration">
                  <property name="store">
                      <bean class="org.gridgain.grid.dr.hub.sender.store.memory.GridDrSenderHubInMemoryStore">
                          <property name="overflowMode" value="REMOVE_OLDEST"/>
                      </bean>
                  </property>
                 ...
              </bean>
          </property>
         ...
 </bean>
 

For information about Spring framework visit www.springframework.org

See Also:

GridDrSenderHubStore

Field Summary

Fields

Modifier and Type	Field and Description
static int	DFLT_MAX_SIZE
static GridDrSenderHubStoreOverflowMode	DFLT_OVERFLOW_MODE

Constructor Summary

Constructors

Constructor and Description
GridDrSenderHubInMemoryStore()

Method Summary

Methods

Modifier and Type	Method and Description
GridDrSenderHubStoreCursor	cursor(byte dataCenterId) Gets cursor for the given data center ID.
int	getMaxSize() Gets maximum number of entries can be stored.
GridDrSenderHubStoreOverflowMode	getOverflowMode() Gets overflow mode defining how store will behave in case of overflow.
void	setMaxSize(int maxSize) Sets maximum number of entries can be stored.
void	setOverflowMode(GridDrSenderHubStoreOverflowMode overflowMode) Sets overflow mode defining how store will behave in case of overflow.
void	start() Starts grid component, called on grid start.
void	stop() Stops grid component, called on grid shutdown.
void	store(byte[] dataCenterIds, byte[] data) Store data.

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_MAX_SIZE

public static final int DFLT_MAX_SIZE

See Also:

Constant Field Values

DFLT_OVERFLOW_MODE

public static final GridDrSenderHubStoreOverflowMode DFLT_OVERFLOW_MODE

Constructor Detail

GridDrSenderHubInMemoryStore

public GridDrSenderHubInMemoryStore()

Method Detail

getMaxSize

public int getMaxSize()

Gets maximum number of entries can be stored. This value should power of two.

Defaults to DFLT_MAX_SIZE.

Returns:

Maximum number of entries in store.

setMaxSize

public void setMaxSize(int maxSize)

Sets maximum number of entries can be stored. See getMaxSize() for more information.

Parameters:

maxSize - Maximum number of entries in store.

getOverflowMode

public GridDrSenderHubStoreOverflowMode getOverflowMode()

Gets overflow mode defining how store will behave in case of overflow.

Defaults to DFLT_OVERFLOW_MODE.

Returns:

Overflow mode.

setOverflowMode

public void setOverflowMode(GridDrSenderHubStoreOverflowMode overflowMode)

Sets overflow mode defining how store will behave in case of overflow. See getOverflowMode() for more information.

Parameters:

overflowMode - Overflow mode.

start

public void start()

Starts grid component, called on grid start.

Specified by:

start in interface GridLifecycleAware

stop

public void stop()

Stops grid component, called on grid shutdown.

Specified by:

stop in interface GridLifecycleAware

store

public void store(byte[] dataCenterIds,
         byte[] data)
           throws GridException

Store data.

Specified by:

store in interface GridDrSenderHubStore

Parameters:

dataCenterIds - Target data center ids.

data - Data center replication store entry.

Throws:

GridException - In case of failure.

GridDrSenderHubStoreOverflowException - If overflowed.

cursor

public GridDrSenderHubStoreCursor cursor(byte dataCenterId)
                                  throws GridException

Gets cursor for the given data center ID.

Specified by:

cursor in interface GridDrSenderHubStore

Parameters:

dataCenterId - Data center ID.

Returns:

Cursor over stored entries which belongs to that data center ID.

Throws:

GridException - If failed.