com.hazelcast.spi.impl.proxyservice.impl

Class ProxyServiceImpl

java.lang.Object

com.hazelcast.spi.impl.proxyservice.impl.ProxyServiceImpl

All Implemented Interfaces:

MetricsProvider, CoreService, EventPublishingService<DistributedObjectEventPacket,Object>, InternalProxyService, PostJoinAwareService, ProxyService

public class ProxyServiceImpl
extends Object
implements InternalProxyService, PostJoinAwareService, EventPublishingService<DistributedObjectEventPacket,Object>, MetricsProvider

Field Summary

Fields

Modifier and Type	Field and Description
static String	SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
ProxyServiceImpl(NodeEngineImpl nodeEngine)

Method Summary

Modifier and Type	Method and Description
String	addProxyListener(DistributedObjectListener distributedObjectListener)
void	destroyDistributedObject(String serviceName, String name)
void	destroyLocalDistributedObject(String serviceName, String name, boolean fireEvent)
void	dispatchEvent(DistributedObjectEventPacket eventPacket, Object ignore) Notifies the service of a published event.
Collection<DistributedObject>	getAllDistributedObjects()
DistributedObject	getDistributedObject(String serviceName, String name)
Collection<String>	getDistributedObjectNames(String serviceName)
Collection<DistributedObject>	getDistributedObjects(String serviceName)
ProxyRegistry	getOrCreateRegistry(String serviceName)
Operation	getPostJoinOperation() Post join operations must be lock free, meaning no locks at all: no partition locks, no key-based locks, no service level locks, no database interaction! The Operation.getPartitionId() method should return a negative value.
int	getProxyCount()
void	init()
void	initializeDistributedObject(String serviceName, String name)
void	provideMetrics(MetricsRegistry registry)
boolean	removeProxyListener(String registrationId)
void	shutdown()

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

See Also:

Constant Field Values

Constructor Detail

ProxyServiceImpl

public ProxyServiceImpl(NodeEngineImpl nodeEngine)

Method Detail

provideMetrics

public void provideMetrics(MetricsRegistry registry)

Specified by:

provideMetrics in interface MetricsProvider

init

public void init()

getProxyCount

public int getProxyCount()

Specified by:

getProxyCount in interface ProxyService

initializeDistributedObject

public void initializeDistributedObject(String serviceName,
                                        String name)

Specified by:

initializeDistributedObject in interface ProxyService

getOrCreateRegistry

public ProxyRegistry getOrCreateRegistry(String serviceName)

getDistributedObject

public DistributedObject getDistributedObject(String serviceName,
                                              String name)

Specified by:

getDistributedObject in interface ProxyService

destroyDistributedObject

public void destroyDistributedObject(String serviceName,
                                     String name)

Specified by:

destroyDistributedObject in interface ProxyService

destroyLocalDistributedObject

public void destroyLocalDistributedObject(String serviceName,
                                          String name,
                                          boolean fireEvent)

Specified by:

destroyLocalDistributedObject in interface InternalProxyService

getDistributedObjects

public Collection<DistributedObject> getDistributedObjects(String serviceName)

Specified by:

getDistributedObjects in interface ProxyService

getDistributedObjectNames

public Collection<String> getDistributedObjectNames(String serviceName)

Specified by:

getDistributedObjectNames in interface ProxyService

getAllDistributedObjects

public Collection<DistributedObject> getAllDistributedObjects()

Specified by:

getAllDistributedObjects in interface ProxyService

addProxyListener

public String addProxyListener(DistributedObjectListener distributedObjectListener)

Specified by:

addProxyListener in interface ProxyService

removeProxyListener

public boolean removeProxyListener(String registrationId)

Specified by:

removeProxyListener in interface ProxyService

dispatchEvent

public void dispatchEvent(DistributedObjectEventPacket eventPacket,
                          Object ignore)

Description copied from interface: EventPublishingService

Notifies the service of a published event.

Specified by:

dispatchEvent in interface EventPublishingService<DistributedObjectEventPacket,Object>

Parameters:

eventPacket - the published event

ignore - the listener registered for this event

getPostJoinOperation

public Operation getPostJoinOperation()

Description copied from interface: PostJoinAwareService

Post join operations must be lock free, meaning no locks at all: no partition locks, no key-based locks, no service level locks, no database interaction! The Operation.getPartitionId() method should return a negative value. This means that the operations should not implement PartitionAwareOperation.

Post join operations should return response, at least a null response.

Specified by:

getPostJoinOperation in interface PostJoinAwareService

Returns:

a response from the post join operation. Can be null.

shutdown

public void shutdown()