Class LoomReliableTopic<T>

java.lang.Object

com.loomcache.client.LoomReliableTopic<T>

Type Parameters:

T - the message type

public final class LoomReliableTopic<T>
extends Object

Client-side reliable-topic proxy with replay by retained sequence.

Method Summary

Modifier and Type	Method	Description
long	publish(T message)
long	publish(T message, TopicOverloadPolicy policy)
List<T>	readFrom(long sequence, int maxCount)
void	unsubscribe()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

publish

public long publish(T message)

publish

public long publish(T message,
 TopicOverloadPolicy policy)

readFrom

public List<T> readFrom(long sequence,
 int maxCount)

unsubscribe

public void unsubscribe()