public abstract class TopicProxySupport extends AbstractDistributedObject<TopicService> implements InitializingObject
PARTITIONING_STRATEGY
Constructor and Description |
---|
TopicProxySupport(String name,
NodeEngine nodeEngine,
TopicService service) |
Modifier and Type | Method and Description |
---|---|
String |
addMessageListenerInternal(MessageListener listener) |
LocalTopicStats |
getLocalTopicStatsInternal() |
String |
getName()
Returns the unique name for this DistributedObject.
|
String |
getServiceName()
Returns the service name for this object.
|
void |
initialize() |
void |
publishInternal(Data message) |
boolean |
removeMessageListenerInternal(String registrationId) |
destroy, equals, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, hashCode, invalidate, postDestroy, throwNotActiveException, toString
public TopicProxySupport(String name, NodeEngine nodeEngine, TopicService service)
public void initialize()
initialize
in interface InitializingObject
public LocalTopicStats getLocalTopicStatsInternal()
public void publishInternal(Data message)
public String addMessageListenerInternal(MessageListener listener)
public boolean removeMessageListenerInternal(String registrationId)
public String getServiceName()
DistributedObject
getServiceName
in interface DistributedObject
getServiceName
in class AbstractDistributedObject<TopicService>
public String getName()
DistributedObject
getName
in interface DistributedObject
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.