com.crankuptheamps.client
Class MemorySubscriptionManager
java.lang.Object
com.crankuptheamps.client.MemorySubscriptionManager
- All Implemented Interfaces:
- SubscriptionManager
public class MemorySubscriptionManager
- extends Object
- implements SubscriptionManager
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MemorySubscriptionManager
public MemorySubscriptionManager()
subscribe
public void subscribe(MessageHandler messageHandler,
int command,
CommandId subId,
String topic,
String filter,
String bookmark,
String options,
int batchSize)
- Specified by:
subscribe
in interface SubscriptionManager
unsubscribe
public void unsubscribe(CommandId subId)
- Specified by:
unsubscribe
in interface SubscriptionManager
clear
public void clear()
- Specified by:
clear
in interface SubscriptionManager
resubscribe
public void resubscribe(Client client)
throws AMPSException
- Specified by:
resubscribe
in interface SubscriptionManager
- Throws:
AMPSException
setDefaultResubscriptionTimeout
public static void setDefaultResubscriptionTimeout(long timeout)