Uses of Interface
com.xxdb.streaming.client.MessageHandler

Packages that use MessageHandler

Package	Description
com.xxdb.streaming.client
com.xxdb.streaming.client.cep

Uses of MessageHandler in com.xxdb.streaming.client

Subinterfaces of MessageHandler in com.xxdb.streaming.client

Modifier and Type	Interface and Description
interface	BatchMessageHandler

Methods in com.xxdb.streaming.client that return MessageHandler

Modifier and Type	Method and Description
MessageHandler	Site.getHandler()

Methods in com.xxdb.streaming.client with parameters of type MessageHandler

Modifier and Type	Method and Description
protected void	ThreadPooledClient.backupSitesSubscribeInternal(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String password, boolean createSubInfo)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, MessageHandler handler)
void	ThreadedClient.subscribe(String host, int port, String tableName, MessageHandler handler)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, MessageHandler handler, boolean reconnect)
void	ThreadedClient.subscribe(String host, int port, String tableName, MessageHandler handler, boolean reconnect)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, MessageHandler handler, long offset)
void	ThreadedClient.subscribe(String host, int port, String tableName, MessageHandler handler, long offset)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, MessageHandler handler, long offset, boolean reconnect)
void	ThreadedClient.subscribe(String host, int port, String tableName, MessageHandler handler, long offset, boolean reconnect)
void	ThreadedClient.subscribe(String host, int port, String tableName, MessageHandler handler, long offset, boolean reconnect, String userName, String password)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, boolean reconnect)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, boolean reconnect)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, String userName, String password)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic, int batchSize, float throttle)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic, int batchSize, float throttle, String userName, String passWord)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic, int batchSize, int throttle)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic, int batchSize, int throttle, String userName, String passWord)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic, String userName, String passWord)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic, String userName, String password)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, int batchSize, float throttle)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, int batchSize, float throttle, String userName, String password)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, int batchSize, int throttle)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, int batchSize, int throttle, String userName, String password)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, int batchSize, int throttle, String userName, String password, List<String> backupSites)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, int batchSize, int throttle, String userName, String password, List<String> backupSites, int resubTimeout, boolean subOnce)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String password)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean msgAsTable)
protected void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String password, boolean createSubInfo) This internal subscribe method only use for when enable backupSite, try to switch site and subscribe.
protected void	PollingClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String password, boolean msgAsTable, boolean createSubInfo)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean msgAsTable, List<String> backupSites)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean msgAsTable, List<String> backupSites, int resubTimeout, boolean subOnce)
void	ThreadPooledClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, Vector filter)
void	ThreadedClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, Vector filter)
protected BlockingQueue<List<IMessage>>	AbstractClient.subscribeInternal(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic)
protected BlockingQueue<List<IMessage>>	AbstractClient.subscribeInternal(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean msgAsTable)
protected BlockingQueue<List<IMessage>>	AbstractClient.subscribeInternal(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean msgAsTable, boolean createSubInfo)
protected BlockingQueue<List<IMessage>>	AbstractClient.subscribeInternal(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean msgAsTable, List<String> backupSites, int resubTimeout, boolean subOnce)
protected BlockingQueue<List<IMessage>>	AbstractClient.subscribeInternal(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean msgAsTable, List<String> backupSites, int resubTimeout, boolean subOnce, boolean createSubInfo)

Uses of MessageHandler in com.xxdb.streaming.client.cep

Classes in com.xxdb.streaming.client.cep that implement MessageHandler

Modifier and Type	Class and Description
class	EventMessageHandler

Methods in com.xxdb.streaming.client.cep with parameters of type MessageHandler

Modifier and Type	Method and Description
void	EventClient.subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, String userName, String password)