com.xxdb.streaming.client.cep

Class EventClient

java.lang.Object

com.xxdb.streaming.client.AbstractClient

com.xxdb.streaming.client.cep.EventClient

public class EventClient
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, resubTimeout, subInfos_, subOnce, tableNameToTrueTopic, trueTopicToSites, users, waitReconnectTopic

Constructor Summary

Constructors

Constructor and Description
EventClient(List<EventSchema> eventSchemas, List<String> eventTimeKeys, List<String> commonKeys)

Method Summary

Modifier and Type	Method and Description
protected boolean	doReconnect(Site site)
void	subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, String userName, String password)
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, 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

EventClient

public EventClient(List<EventSchema> eventSchemas,
                   List<String> eventTimeKeys,
                   List<String> commonKeys)
            throws SocketException

Throws:

SocketException

Method Detail

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

unsubscribe

public void unsubscribe(String host,
                        int port,
                        String tableName,
                        String actionName)
                 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

doReconnect

protected boolean doReconnect(Site site)

Specified by:

doReconnect in class AbstractClient