com.hazelcast.replicatedmap.impl
Class ReplicatedMapService

java.lang.Object
  com.hazelcast.replicatedmap.impl.ReplicatedMapService

All Implemented Interfaces:

EventPublishingService<Object,Object>, ManagedService, RemoteService

public class ReplicatedMapService
extends Object
implements ManagedService, RemoteService, EventPublishingService<Object,Object>

This is the main service implementation to handle replication and manages the backing ReplicatedRecordStores that actually hold the data

Field Summary

static String	EVENT_TOPIC_NAME Public constant for the internal name of the replication topic
static String	SERVICE_NAME Public constant for the internal service name of the ReplicatedMapService

Constructor Summary

ReplicatedMapService(NodeEngine nodeEngine)

Method Summary

String	addEventListener(EventListener entryListener, EventFilter eventFilter, String mapName)
DistributedObject	createDistributedObject(String objectName) Creates a distributed object.
void	destroyDistributedObject(String objectName) Destroys a distributed object.
void	dispatchEvent(Object event, Object listener)
ReplicatedMapConfig	getReplicatedMapConfig(String name)
ReplicatedRecordStore	getReplicatedRecordStore(String name, boolean create)
void	init(NodeEngine nodeEngine, Properties properties) Initializes this ManagedService
boolean	removeEventListener(String mapName, String registrationId)
void	reset() reset this ManagedService back to initial state.
void	shutdown(boolean terminate) Shuts down this ManagedService.

Methods inherited from class java.lang.Object

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

Field Detail

SERVICE_NAME

public static final String SERVICE_NAME

Public constant for the internal service name of the ReplicatedMapService

See Also:

Constant Field Values

EVENT_TOPIC_NAME

public static final String EVENT_TOPIC_NAME

Public constant for the internal name of the replication topic

See Also:

Constant Field Values

Constructor Detail

ReplicatedMapService

public ReplicatedMapService(NodeEngine nodeEngine)

Method Detail

init

public void init(NodeEngine nodeEngine,
                 Properties properties)

Description copied from interface: ManagedService

Initializes this ManagedService

Specified by:

init in interface ManagedService

Parameters:

nodeEngine - the NodeEngine that this ManagedService belongs to.

properties - the Properties. Can be used to pass settings to the service.

reset

public void reset()

Description copied from interface: ManagedService

reset this ManagedService back to initial state. todo: what is the purpose of reset

Specified by:

reset in interface ManagedService

shutdown

public void shutdown(boolean terminate)

Description copied from interface: ManagedService

Shuts down this ManagedService. todo: what is the purpose of the terminate variable.

Specified by:

shutdown in interface ManagedService

Parameters:

terminate - true to shut down the ManagedService

createDistributedObject

public DistributedObject createDistributedObject(String objectName)

Description copied from interface: RemoteService

Creates a distributed object.

Specified by:

createDistributedObject in interface RemoteService

Parameters:

objectName - the name for the created distributed object

Returns:

the created distributed object

destroyDistributedObject

public void destroyDistributedObject(String objectName)

Description copied from interface: RemoteService

Destroys a distributed object.

Specified by:

destroyDistributedObject in interface RemoteService

Parameters:

objectName - the name of the distributed object to destroy

dispatchEvent

public void dispatchEvent(Object event,
                          Object listener)

Specified by:

dispatchEvent in interface EventPublishingService<Object,Object>

getReplicatedMapConfig

public ReplicatedMapConfig getReplicatedMapConfig(String name)

getReplicatedRecordStore

public ReplicatedRecordStore getReplicatedRecordStore(String name,
                                                      boolean create)

addEventListener

public String addEventListener(EventListener entryListener,
                               EventFilter eventFilter,
                               String mapName)

removeEventListener

public boolean removeEventListener(String mapName,
                                   String registrationId)