public class ClientReliableTopicProxy<E> extends ClientProxy implements ITopic<E>
Modifier and Type | Field and Description |
---|---|
static int |
INITIAL_BACKOFF_MS |
static int |
MAX_BACKOFF |
name
Constructor and Description |
---|
ClientReliableTopicProxy(String objectId,
HazelcastClientInstanceImpl client) |
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
|
Ringbuffer |
getRingbuffer() |
void |
publish(E payload)
Publishes the message to all subscribers of this topic
|
boolean |
removeMessageListener(String registrationId)
Stops receiving messages for the given message listener.
|
String |
toString() |
deregisterListener, destroy, equals, getClient, getContext, getId, getName, getPartitionKey, getServiceName, hashCode, invoke, invoke, invokeOnPartition, invokeOnPartitionInterruptibly, onDestroy, onInitialize, onShutdown, registerListener, setContext, throwExceptionIfNull, toData, toObject
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
destroy, getPartitionKey, getServiceName
public static final int MAX_BACKOFF
public static final int INITIAL_BACKOFF_MS
public ClientReliableTopicProxy(String objectId, HazelcastClientInstanceImpl client)
public void publish(E payload)
ITopic
public String addMessageListener(MessageListener<E> listener)
ITopic
addMessageListener
in interface ITopic<E>
listener
- the MessageListener to add.public boolean removeMessageListener(String registrationId)
ITopic
removeMessageListener
in interface ITopic<E>
registrationId
- Id of listener registration.public LocalTopicStats getLocalTopicStats()
ITopic
getLocalTopicStats
in interface ITopic<E>
public Ringbuffer getRingbuffer()
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.