com.xxdb.streaming.client

Class ThreadPooledClient

java.lang.Object

com.xxdb.streaming.client.AbstractClient

com.xxdb.streaming.client.ThreadPooledClient

public class ThreadPooledClient
extends AbstractClient

Nested Class Summary

Nested classes/interfaces inherited from class com.xxdb.streaming.client.AbstractClient

AbstractClient.HAStreamTableInfo

Field Summary

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

connList, currentSiteIndexMap, DEFAULT_ACTION_NAME, DEFAULT_HOST, DEFAULT_PORT, haStreamTableInfo, 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
ThreadPooledClient()
ThreadPooledClient(int threadCount)
ThreadPooledClient(int subscribePort, int threadCount)
ThreadPooledClient(String subscribeHost, int subscribePort, int threadCount)

Method Summary

Modifier and Type	Method and Description
protected void	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	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, 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, Vector filter, boolean allowExistTopic)
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, 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, String userName, String passWord, boolean msgAsTable)
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 msgAsTable, 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, String userName, String passWord, boolean msgAsTable, List<String> backupSites, int resubscribeInterval, boolean subOnce)
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, getNewLeader, getReconnectTimestamp, getSiteByName, getSubInfos, getTopicToSites, isClose, isClosed, isRemoteLittleEndian, setMsgId, setNeedReconnect, setReconnectTimestamp, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeInternal, subscribeStreamingSqlLogInfoInternal, tryReconnect, unsubscribeInternal

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadPooledClient

public ThreadPooledClient()
                   throws SocketException

Throws:

SocketException

ThreadPooledClient

public ThreadPooledClient(int threadCount)
                   throws SocketException

Throws:

SocketException

ThreadPooledClient

public ThreadPooledClient(int subscribePort,
                          int threadCount)
                   throws SocketException

Throws:

SocketException

ThreadPooledClient

public ThreadPooledClient(String subscribeHost,
                          int subscribePort,
                          int threadCount)
                   throws SocketException

Throws:

SocketException

Method Detail

doReconnect

protected boolean doReconnect(Site site)

Specified by:

doReconnect in class AbstractClient

backupSitesSubscribeInternal

protected void 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)
                                     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,
                      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,
                      String userName,
                      String passWord,
                      boolean msgAsTable)
               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,
                      String userName,
                      String passWord,
                      boolean msgAsTable,
                      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,
                      String userName,
                      String passWord,
                      boolean msgAsTable,
                      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,
                      boolean allowExistTopic,
                      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)
               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 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

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