com.hazelcast.topic.impl

Class TotalOrderedTopicProxy<E>

java.lang.Object

com.hazelcast.spi.AbstractDistributedObject<TopicService>

com.hazelcast.topic.impl.TopicProxySupport

com.hazelcast.topic.impl.TopicProxy<E>

com.hazelcast.topic.impl.TotalOrderedTopicProxy<E>

Type Parameters:

E - the type of message in this topic

All Implemented Interfaces:

DistributedObject, ITopic<E>, InitializingObject

public class TotalOrderedTopicProxy<E>
extends TopicProxy<E>

Topic proxy used when global ordering is enabled (all nodes listening to the same topic get their messages in the same order).

Field Summary

Fields inherited from class com.hazelcast.spi.AbstractDistributedObject

PARTITIONING_STRATEGY

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	publish(E message) Publishes the message to all subscribers of this topic

Methods inherited from class com.hazelcast.topic.impl.TopicProxy

addMessageListener, getLocalTopicStats, removeMessageListener

Methods inherited from class com.hazelcast.topic.impl.TopicProxySupport

addMessageListenerInternal, getLocalTopicStatsInternal, getName, getServiceName, initialize, publishInternal, removeMessageListenerInternal

Methods inherited from class com.hazelcast.spi.AbstractDistributedObject

destroy, equals, getDistributedObjectName, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, hashCode, invalidate, invokeOnPartition, postDestroy, preDestroy, throwNotActiveException, toData, 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, getPartitionKey, getServiceName

Constructor Detail

TotalOrderedTopicProxy

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

Method Detail

publish

public void publish(E message)

Description copied from interface: ITopic

Publishes the message to all subscribers of this topic

Specified by:

publish in interface ITopic<E>

Overrides:

publish in class TopicProxy<E>

Parameters:

message - the message to publish to all subscribers of this topic