com.xxdb.streaming.client

Class ThreadedClient

java.lang.Object

com.xxdb.streaming.client.AbstractClient

com.xxdb.streaming.client.ThreadedClient

public class ThreadedClient
extends AbstractClient

Field Summary

Fields inherited from class com.xxdb.streaming.client.AbstractClient

connList, currentSiteIndexMap, DEFAULT_ACTION_NAME, DEFAULT_HOST, DEFAULT_PORT, HATopicToTrueTopic, hostEndian, ifUseBackupSite, isClose_, lastBackupSiteTopic, lastExceptionTopicTimeMap, lastQueue, lastSuccessSubscribeTopic, listeningHost, listeningPort, messageCache, pThread, queueManager, reconnectTable, resubscribeInterval, subInfos_, subOnce, tableNameToTrueTopic, trueTopicToSites, users, waitReconnectTopic

Constructor Summary

Constructors

Constructor and Description
ThreadedClient()
ThreadedClient(int subscribePort)
ThreadedClient(String subscribeHost, int subscribePort)

Method Summary

Modifier and Type	Method and Description
void	close()
protected boolean	doReconnect(Site site)
void	subscribe(String host, int port, String tableName, MessageHandler handler)
void	subscribe(String host, int port, String tableName, MessageHandler handler, boolean reconnect)
void	subscribe(String host, int port, String tableName, MessageHandler handler, long offset)
void	subscribe(String host, int port, String tableName, MessageHandler handler, long offset, boolean reconnect)
void	subscribe(String host, int port, String tableName, MessageHandler handler, long offset, boolean reconnect, String userName, String password)
void	subscribe(String host, int port, String tableName, String actionName, BatchMessageHandler batchMessageHandler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic, int batchSize, float throttle)
void	subscribe(String host, int port, String tableName, String actionName, BatchMessageHandler batchMessageHandler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic, int batchSize, float throttle, String userName, String passWord)
void	subscribe(String host, int port, String tableName, String actionName, BatchMessageHandler batchMessageHandler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic, int batchSize, int throttle)
void	subscribe(String host, int port, String tableName, String actionName, BatchMessageHandler batchMessageHandler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic, int batchSize, int throttle, String userName, String passWord)
void	subscribe(String host, int port, String tableName, String actionName, BatchMessageHandler batchMessageHandler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, int batchSize, float throttle)
void	subscribe(String host, int port, String tableName, String actionName, BatchMessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, int batchSize, float throttle, String userName, String password)
void	subscribe(String host, int port, String tableName, String actionName, BatchMessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, int batchSize, float throttle, String userName, String password, boolean msgAsTable)
void	subscribe(String host, int port, String tableName, String actionName, BatchMessageHandler batchMessageHandler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, int batchSize, int throttle)
void	subscribe(String host, int port, String tableName, String actionName, BatchMessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, int batchSize, int throttle, String userName, String password)
void	subscribe(String host, int port, String tableName, String actionName, MessageHandler handler)
void	subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, boolean reconnect)
void	subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset)
void	subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect)
void	subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, String userName, String password)
void	subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic)
void	subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic, int batchSize, float throttle)
void	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	subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic, int batchSize, int throttle)
void	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	subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, boolean allowExistTopic, String userName, String password)
void	subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer)
void	subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic)
void	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	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	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	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	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	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 resubscribeInterval, boolean subOnce)
void	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)
protected void	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.
void	subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, Vector filter)
void	unsubscribe(String host, int port, String tableName)
void	unsubscribe(String host, int port, String tableName, String actionName)
protected void	unsubscribeInternal(String host, int port, String tableName, String actionName)

Methods inherited from class com.xxdb.streaming.client.AbstractClient

activeCloseConnection, batchDispatch, dispatch, getAllReconnectSites, getAllReconnectTopic, getAllTopicsBySite, getCurrentSiteByName, getNeedReconnect, getReconnectTimestamp, getSiteByName, getSubInfos, getTopicToSites, isClose, isClosed, isRemoteLittleEndian, setMsgId, setNeedReconnect, setReconnectTimestamp, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, tryReconnect, unsubscribeInternal

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadedClient

public ThreadedClient()
               throws SocketException

Throws:

SocketException

ThreadedClient

public ThreadedClient(int subscribePort)
               throws SocketException

Throws:

SocketException

ThreadedClient

public ThreadedClient(String subscribeHost,
                      int subscribePort)
               throws SocketException

Throws:

SocketException

Method Detail

doReconnect

protected boolean doReconnect(Site site)

Specified by:

doReconnect in class AbstractClient

subscribe

public void 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)
               throws IOException

Throws:

IOException

subscribe

protected void 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)
                  throws IOException

This internal subscribe method only use for when enable backupSite, try to switch site and subscribe.

Throws:

IOException

subscribe

public void 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)
               throws IOException

Throws:

IOException

subscribe

public void 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 resubscribeInterval,
                      boolean subOnce)
               throws IOException

Throws:

IOException

subscribe

public void 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)
               throws IOException

Throws:

IOException

subscribe

public void 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)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      BatchMessageHandler handler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      StreamDeserializer deserializer,
                      boolean allowExistTopic,
                      int batchSize,
                      float throttle,
                      String userName,
                      String password)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      BatchMessageHandler handler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      StreamDeserializer deserializer,
                      boolean allowExistTopic,
                      int batchSize,
                      float throttle,
                      String userName,
                      String password,
                      boolean msgAsTable)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      BatchMessageHandler handler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      StreamDeserializer deserializer,
                      boolean allowExistTopic,
                      int batchSize,
                      int throttle,
                      String userName,
                      String password)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      MessageHandler handler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      boolean allowExistTopic,
                      String userName,
                      String password)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      BatchMessageHandler batchMessageHandler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      StreamDeserializer deserializer,
                      boolean allowExistTopic,
                      int batchSize,
                      float throttle)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      BatchMessageHandler batchMessageHandler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      StreamDeserializer deserializer,
                      boolean allowExistTopic,
                      int batchSize,
                      int throttle)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      BatchMessageHandler batchMessageHandler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      boolean allowExistTopic,
                      int batchSize,
                      float throttle)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      BatchMessageHandler batchMessageHandler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      boolean allowExistTopic,
                      int batchSize,
                      int throttle)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      BatchMessageHandler batchMessageHandler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      boolean allowExistTopic,
                      int batchSize,
                      float throttle,
                      String userName,
                      String passWord)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      BatchMessageHandler batchMessageHandler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      boolean allowExistTopic,
                      int batchSize,
                      int throttle,
                      String userName,
                      String passWord)
               throws IOException

Throws:

IOException

subscribe

public void 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)
               throws IOException

Throws:

IOException

subscribe

public void 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)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      MessageHandler handler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      StreamDeserializer deserializer,
                      boolean allowExistTopic)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      MessageHandler handler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      boolean allowExistTopic)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      MessageHandler handler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      StreamDeserializer deserializer)
               throws Exception

Throws:

Exception

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      MessageHandler handler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      boolean allowExistTopic,
                      int batchSize,
                      int throttle)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      MessageHandler handler,
                      long offset,
                      boolean reconnect,
                      Vector filter,
                      boolean allowExistTopic,
                      int batchSize,
                      float throttle)
               throws IOException

Throws:

IOException

subscribe

public void 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)
               throws IOException

Throws:

IOException

subscribe

public void 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)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      MessageHandler handler,
                      long offset,
                      boolean reconnect,
                      String userName,
                      String password)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      MessageHandler handler,
                      long offset,
                      boolean reconnect)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      MessageHandler handler,
                      long offset,
                      Vector filter)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      MessageHandler handler,
                      long offset)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      MessageHandler handler)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      String actionName,
                      MessageHandler handler,
                      boolean reconnect)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      MessageHandler handler)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      MessageHandler handler,
                      boolean reconnect)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      MessageHandler handler,
                      long offset)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      MessageHandler handler,
                      long offset,
                      boolean reconnect)
               throws IOException

Throws:

IOException

subscribe

public void subscribe(String host,
                      int port,
                      String tableName,
                      MessageHandler handler,
                      long offset,
                      boolean reconnect,
                      String userName,
                      String password)
               throws IOException

Throws:

IOException

unsubscribe

public void unsubscribe(String host,
                        int port,
                        String tableName,
                        String actionName)
                 throws IOException

Throws:

IOException

unsubscribe

public void unsubscribe(String host,
                        int port,
                        String tableName)
                 throws IOException

Throws:

IOException

unsubscribeInternal

protected void unsubscribeInternal(String host,
                                   int port,
                                   String tableName,
                                   String actionName)
                            throws IOException

Overrides:

unsubscribeInternal in class AbstractClient

Throws:

IOException

close

public void close()

Overrides:

close in class AbstractClient