com.crankuptheamps.client
Class MemorySubscriptionManager

java.lang.Object
  extended by com.crankuptheamps.client.MemorySubscriptionManager
All Implemented Interfaces:
SubscriptionManager

public class MemorySubscriptionManager
extends Object
implements SubscriptionManager


Constructor Summary
MemorySubscriptionManager()
           
 
Method Summary
 void clear()
           
 void resubscribe(Client client)
           
static void setDefaultResubscriptionTimeout(long timeout)
           
 void subscribe(MessageHandler messageHandler, int command, CommandId subId, String topic, String filter, String bookmark, String options, int batchSize)
           
 void unsubscribe(CommandId subId)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MemorySubscriptionManager

public MemorySubscriptionManager()
Method Detail

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)