com.hazelcast.core
public interface ITopic<E> extends DistributedObject
Ringbuffer
to store events and to gets its own executor to process events. The events
in the rinbuffer are replicated, so they won't get lost when a node goes down.Modifier and Type | Method and Description |
---|---|
String |
addMessageListener(MessageListener<E> listener)
Subscribes to this topic.
|
LocalTopicStats |
getLocalTopicStats()
Returns statistics about this topic, like total number of publishes/receives
|
String |
getName()
Returns the name of this ITopic instance
|
void |
publish(E message)
Publishes the message to all subscribers of this topic
|
boolean |
removeMessageListener(String registrationId)
Stops receiving messages for the given message listener.
|
destroy, getId, getPartitionKey, getServiceName
String getName()
getName
in interface DistributedObject
void publish(E message)
message
- the message to publish to all subscribers of this topicTopicOverloadException
- if the consumer is too slow. Only works in combination with
reliable topic.String addMessageListener(MessageListener<E> listener)
listener
- the MessageListener to add.NullPointerException
- if listener is null.boolean removeMessageListener(String registrationId)
registrationId
- Id of listener registration.LocalTopicStats getLocalTopicStats()
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.