com.hazelcast.spi.impl.proxyservice.impl

Class ProxyServiceImpl

java.lang.Object

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

All Implemented Interfaces:

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

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

Field Summary

Fields

Modifier and Type	Field and Description
static String	SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
ProxyServiceImpl(NodeEngineImpl nodeEngine)

Method Summary

Methods

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)
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!
int	getProxyCount()
void	init()
void	initializeDistributedObject(String serviceName, String name)
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

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)

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)

Specified by:

dispatchEvent in interface EventPublishingService<DistributedObjectEventPacket,Object>

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!

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()