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

Packages that use IMessage

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

Uses of IMessage in com.xxdb.streaming.client

Classes in com.xxdb.streaming.client that implement IMessage

Modifier and Type	Class and Description
class	BasicMessage

Fields in com.xxdb.streaming.client with type parameters of type IMessage

Modifier and Type	Field and Description
protected BlockingQueue<List<IMessage>>	AbstractClient.lastQueue
protected ConcurrentHashMap<String,List<IMessage>>	AbstractClient.messageCache

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

Modifier and Type	Method and Description
IMessage	TopicPoller.take()

Methods in com.xxdb.streaming.client that return types with arguments of type IMessage

Modifier and Type	Method and Description
BlockingQueue<List<IMessage>>	TopicManager.addMessageQueue(String topic)
BlockingQueue<List<IMessage>>	QueueManager.addQueue(String topic)
BlockingQueue<List<IMessage>>	TopicManager.getMessageQueue(String topic)
BlockingQueue<List<IMessage>>	QueueManager.getQueue(String topic)
ArrayList<IMessage>	TopicPoller.poll(long timeout)
ArrayList<IMessage>	TopicPoller.poll(long timeout, int size)
protected BlockingQueue<List<IMessage>>	AbstractClient.subscribeInternal(String host, int port, String tableName, long offset)
protected BlockingQueue<List<IMessage>>	AbstractClient.subscribeInternal(String host, int port, String tableName, String actionName, long offset)
protected BlockingQueue<List<IMessage>>	AbstractClient.subscribeInternal(String host, int port, String tableName, String actionName, long offset, boolean reconnect)
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 resubscribeInterval, 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 resubscribeInterval, boolean subOnce, boolean createSubInfo)

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

Modifier and Type	Method and Description
void	AbstractClient.dispatch(IMessage msg)
void	MessageHandler.doEvent(IMessage msg)
BasicMessage	StreamDeserializer.parse(IMessage message)

Method parameters in com.xxdb.streaming.client with type arguments of type IMessage

Modifier and Type	Method and Description
void	AbstractClient.batchDispatch(List<IMessage> messags)
void	BatchMessageHandler.batchHandler(List<IMessage> msgs)
void	QueueManager.changeQueue(String topic, BlockingQueue<List<IMessage>> q)
void	TopicPoller.setQueue(BlockingQueue<List<IMessage>> queue)

Constructor parameters in com.xxdb.streaming.client with type arguments of type IMessage

Constructor and Description
TopicPoller(BlockingQueue<List<IMessage>> queue)

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

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

Modifier and Type	Method and Description
void	EventMessageHandler.doEvent(IMessage msg)

Method parameters in com.xxdb.streaming.client.cep with type arguments of type IMessage

Modifier and Type	Method and Description
boolean	EventHandler.deserializeEvent(List<IMessage> msgs, List<String> eventTypes, List<List<Entity>> attributes, ErrorCodeInfo errorInfo)

Uses of IMessage in com.xxdb.streaming.client.streamingSQL

Methods in com.xxdb.streaming.client.streamingSQL that return types with arguments of type IMessage

Modifier and Type	Method and Description
List<IMessage>	UpdateEvent.getRawMessages()

Methods in com.xxdb.streaming.client.streamingSQL with parameters of type IMessage

Modifier and Type	Method and Description
protected static StreamingSQLResultUpdater.StreamingSQLResult	StreamingSQLResultUpdater.updateStreamingSQLResult(BasicTable result, BasicIntVector deleteLineMap, IMessage msg) Update streaming SQL result table

Constructor parameters in com.xxdb.streaming.client.streamingSQL with type arguments of type IMessage

Constructor and Description
UpdateEvent(String queryId, BasicTable table, List<ChangeRecord> changeRecords, List<IMessage> rawMessages, long appliedAtMillis)