com.hazelcast.topic.impl

Class TopicProxySupport

java.lang.Object

com.hazelcast.spi.AbstractDistributedObject<TopicService>

com.hazelcast.topic.impl.TopicProxySupport

All Implemented Interfaces:

DistributedObject, InitializingObject

Direct Known Subclasses:

TopicProxy

public abstract class TopicProxySupport
extends AbstractDistributedObject<TopicService>
implements InitializingObject

Field Summary

Fields inherited from class com.hazelcast.spi.AbstractDistributedObject

PARTITIONING_STRATEGY

Constructor Summary

Constructors

Constructor and Description
TopicProxySupport(String name, NodeEngine nodeEngine, TopicService service)

Method Summary

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(Object message) Publishes the message and increases the local statistics for the number of published messages.
boolean	removeMessageListenerInternal(String registrationId)

Methods inherited from class com.hazelcast.spi.AbstractDistributedObject

destroy, equals, getDistributedObjectName, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, hashCode, invalidate, invokeOnPartition, isClusterVersionEqualTo, isClusterVersionGreaterOrEqual, isClusterVersionGreaterThan, isClusterVersionLessOrEqual, isClusterVersionLessThan, isClusterVersionUnknown, isClusterVersionUnknownOrGreaterOrEqual, isClusterVersionUnknownOrGreaterThan, isClusterVersionUnknownOrLessOrEqual, isClusterVersionUnknownOrLessThan, postDestroy, preDestroy, throwNotActiveException, toData, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

TopicProxySupport

public TopicProxySupport(String name,
                         NodeEngine nodeEngine,
                         TopicService service)

Method Detail

initialize

public void initialize()

Specified by:

initialize in interface InitializingObject

getLocalTopicStatsInternal

public LocalTopicStats getLocalTopicStatsInternal()

publishInternal

public void publishInternal(Object message)

Publishes the message and increases the local statistics for the number of published messages.

Parameters:

message - the message to be published

addMessageListenerInternal

public String addMessageListenerInternal(MessageListener listener)

removeMessageListenerInternal

public boolean removeMessageListenerInternal(String registrationId)

getServiceName

public String getServiceName()

Description copied from interface: DistributedObject

Returns the service name for this object.

Specified by:

getServiceName in interface DistributedObject

Specified by:

getServiceName in class AbstractDistributedObject<TopicService>

Returns:

the service name for this object.

getName

public String getName()

Description copied from interface: DistributedObject

Returns the unique name for this DistributedObject. The returned value will never be null. The suggested way for getting name is retrieving it through DistributedObjectUtil.getName(DistributedObject) because this might be also a PrefixedDistributedObject.

Specified by:

getName in interface DistributedObject

Returns:

the unique name for this object.