com.hazelcast.topic.impl
Class TotalOrderedTopicProxy

java.lang.Object
  extended by com.hazelcast.spi.AbstractDistributedObject<TopicService>
      extended by com.hazelcast.topic.impl.TopicProxy
          extended by com.hazelcast.topic.impl.TotalOrderedTopicProxy
All Implemented Interfaces:
DistributedObject, ITopic, InitializingObject

public class TotalOrderedTopicProxy
extends TopicProxy


Field Summary
 
Fields inherited from class com.hazelcast.spi.AbstractDistributedObject
PARTITIONING_STRATEGY
 
Constructor Summary
TotalOrderedTopicProxy(String name, NodeEngine nodeEngine, TopicService service)
           
 
Method Summary
 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 publish(Object message)
          Publishes the message to all subscribers of this topic
 void publishInternal(Data message)
           
 boolean removeMessageListenerInternal(String registrationId)
           
 
Methods inherited from class com.hazelcast.topic.impl.TopicProxy
addMessageListener, getLocalTopicStats, removeMessageListener
 
Methods inherited from class com.hazelcast.spi.AbstractDistributedObject
destroy, equals, getId, getNameAsPartitionAwareData, getNodeEngine, getPartitionKey, getService, hashCode, invalidate, postDestroy, throwNotActiveException, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface com.hazelcast.core.ITopic
getName
 
Methods inherited from interface com.hazelcast.core.DistributedObject
destroy, getId, getPartitionKey, getServiceName
 

Constructor Detail

TotalOrderedTopicProxy

public TotalOrderedTopicProxy(String name,
                              NodeEngine nodeEngine,
                              TopicService service)
Method Detail

publish

public void publish(Object message)
Description copied from interface: ITopic
Publishes the message to all subscribers of this topic

Specified by:
publish in interface ITopic
Overrides:
publish in class TopicProxy
Parameters:
message - the message to publish to all subscribers of this topic

initialize

public void initialize()
Specified by:
initialize in interface InitializingObject

getLocalTopicStatsInternal

public LocalTopicStats getLocalTopicStatsInternal()

publishInternal

public void publishInternal(Data message)

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.

Specified by:
getName in interface DistributedObject
Returns:
the unique name for this object.


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.