com.xxdb.streaming.client

Class PollingClient

java.lang.Object

com.xxdb.streaming.client.AbstractClient

com.xxdb.streaming.client.PollingClient

public class PollingClient
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
PollingClient()
PollingClient(int subscribePort)
PollingClient(String subscribeHost, int subscribePort)

Method Summary

Modifier and Type	Method and Description
protected boolean	doReconnect(Site site)
TopicPoller	subscribe(String host, int port, String tableName)
TopicPoller	subscribe(String host, int port, String tableName, boolean reconnect)
TopicPoller	subscribe(String host, int port, String tableName, long offset)
TopicPoller	subscribe(String host, int port, String tableName, long offset, boolean reconnect)
TopicPoller	subscribe(String host, int port, String tableName, String actionName)
TopicPoller	subscribe(String host, int port, String tableName, String actionName, boolean reconnect)
TopicPoller	subscribe(String host, int port, String tableName, String actionName, long offset)
TopicPoller	subscribe(String host, int port, String tableName, String actionName, long offset, boolean reconnect)
TopicPoller	subscribe(String host, int port, String tableName, String actionName, long offset, boolean reconnect, Vector filter)
TopicPoller	subscribe(String host, int port, String tableName, String actionName, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer)
TopicPoller	subscribe(String host, int port, String tableName, String actionName, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, String userName, String passWord)
TopicPoller	subscribe(String host, int port, String tableName, String actionName, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, String userName, String passWord, boolean msgAsTable)
TopicPoller	subscribe(String host, int port, String tableName, String actionName, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, String userName, String passWord, boolean msgAsTable, List<String> backupSites)
TopicPoller	subscribe(String host, int port, String tableName, String actionName, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, String userName, String passWord, boolean msgAsTable, List<String> backupSites, int resubscribeInterval, boolean subOnce)
TopicPoller	subscribe(String host, int port, String tableName, String actionName, long offset, boolean reconnect, Vector filter, String userName, String passWord)
TopicPoller	subscribe(String host, int port, String tableName, String actionName, long offset, Vector filter)
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 msgAsTable, boolean createSubInfo)
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, close, 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

PollingClient

public PollingClient()
              throws SocketException

Throws:

SocketException

PollingClient

public PollingClient(int subscribePort)
              throws SocketException

Throws:

SocketException

PollingClient

public PollingClient(String subscribeHost,
                     int subscribePort)
              throws SocketException

Throws:

SocketException

Method Detail

doReconnect

protected boolean doReconnect(Site site)

Specified by:

doReconnect in class AbstractClient

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 msgAsTable,
                         boolean createSubInfo)
                  throws IOException

Throws:

IOException

subscribe

public TopicPoller subscribe(String host,
                             int port,
                             String tableName,
                             String actionName,
                             long offset,
                             boolean reconnect,
                             Vector filter,
                             StreamDeserializer deserializer,
                             String userName,
                             String passWord)
                      throws IOException

Throws:

IOException

subscribe

public TopicPoller subscribe(String host,
                             int port,
                             String tableName,
                             String actionName,
                             long offset,
                             boolean reconnect,
                             Vector filter,
                             StreamDeserializer deserializer,
                             String userName,
                             String passWord,
                             boolean msgAsTable)
                      throws IOException

Throws:

IOException

subscribe

public TopicPoller subscribe(String host,
                             int port,
                             String tableName,
                             String actionName,
                             long offset,
                             boolean reconnect,
                             Vector filter,
                             StreamDeserializer deserializer,
                             String userName,
                             String passWord,
                             boolean msgAsTable,
                             List<String> backupSites,
                             int resubscribeInterval,
                             boolean subOnce)
                      throws IOException

Throws:

IOException

subscribe

public TopicPoller subscribe(String host,
                             int port,
                             String tableName,
                             String actionName,
                             long offset,
                             boolean reconnect,
                             Vector filter,
                             StreamDeserializer deserializer,
                             String userName,
                             String passWord,
                             boolean msgAsTable,
                             List<String> backupSites)
                      throws IOException

Throws:

IOException

subscribe

public TopicPoller subscribe(String host,
                             int port,
                             String tableName,
                             String actionName,
                             long offset,
                             boolean reconnect,
                             Vector filter,
                             String userName,
                             String passWord)
                      throws IOException

Throws:

IOException

subscribe

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

Throws:

IOException

subscribe

public TopicPoller subscribe(String host,
                             int port,
                             String tableName,
                             String actionName,
                             long offset,
                             boolean reconnect,
                             Vector filter)
                      throws IOException

Throws:

IOException

subscribe

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

Throws:

IOException

subscribe

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

Throws:

IOException

subscribe

public TopicPoller subscribe(String host,
                             int port,
                             String tableName,
                             String actionName,
                             long offset)
                      throws IOException

Throws:

IOException

subscribe

public TopicPoller subscribe(String host,
                             int port,
                             String tableName,
                             long offset)
                      throws IOException

Throws:

IOException

subscribe

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

Throws:

IOException

subscribe

public TopicPoller subscribe(String host,
                             int port,
                             String tableName)
                      throws IOException

Throws:

IOException

subscribe

public TopicPoller subscribe(String host,
                             int port,
                             String tableName,
                             boolean reconnect)
                      throws IOException

Throws:

IOException

subscribe

public TopicPoller subscribe(String host,
                             int port,
                             String tableName,
                             String actionName)
                      throws IOException

Throws:

IOException

subscribe

public TopicPoller subscribe(String host,
                             int port,
                             String tableName,
                             String actionName,
                             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