public class ProxyServiceImpl extends Object implements InternalProxyService, PostJoinAwareService, EventPublishingService<DistributedObjectEventPacket,Object>, MetricsProvider
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME |
Constructor and Description |
---|
ProxyServiceImpl(NodeEngineImpl nodeEngine) |
public static final String SERVICE_NAME
public ProxyServiceImpl(NodeEngineImpl nodeEngine)
public void provideMetrics(MetricsRegistry registry)
provideMetrics
in interface MetricsProvider
public void init()
public int getProxyCount()
getProxyCount
in interface ProxyService
public void initializeAndPublishProxies()
public void initializeDistributedObject(String serviceName, String name)
initializeDistributedObject
in interface ProxyService
public ProxyRegistry getOrCreateRegistry(String serviceName)
public DistributedObject getDistributedObject(String serviceName, String name)
getDistributedObject
in interface ProxyService
public void destroyDistributedObject(String serviceName, String name)
destroyDistributedObject
in interface ProxyService
public void destroyLocalDistributedObject(String serviceName, String name, boolean fireEvent)
destroyLocalDistributedObject
in interface InternalProxyService
public Collection<DistributedObject> getDistributedObjects(String serviceName)
getDistributedObjects
in interface ProxyService
public Collection<String> getDistributedObjectNames(String serviceName)
getDistributedObjectNames
in interface ProxyService
public Collection<DistributedObject> getAllDistributedObjects()
getAllDistributedObjects
in interface ProxyService
public String addProxyListener(DistributedObjectListener distributedObjectListener)
addProxyListener
in interface ProxyService
public boolean removeProxyListener(String registrationId)
removeProxyListener
in interface ProxyService
public void dispatchEvent(DistributedObjectEventPacket eventPacket, Object ignore)
EventPublishingService
dispatchEvent
in interface EventPublishingService<DistributedObjectEventPacket,Object>
eventPacket
- the published eventignore
- the listener registered for this eventpublic Operation getPostJoinOperation()
PostJoinAwareService
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.
getPostJoinOperation
in interface PostJoinAwareService
null
.public void shutdown()
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.