com.xxdb.streaming.client

Class BasicMessage

java.lang.Object

com.xxdb.streaming.client.BasicMessage

All Implemented Interfaces:

IMessage

public class BasicMessage
extends Object
implements IMessage

Constructor Summary

Constructors

Constructor and Description
BasicMessage(long offset, String topic, BasicAnyVector msg, HashMap<String,Integer> nameToIndex)
BasicMessage(long offset, String topic, BasicAnyVector msg, String sym)

Method Summary

Modifier and Type	Method and Description
Entity	getEntity(int colIndex)
Entity	getMsg()
long	getOffset()
String	getSym()
String	getTopic()
<T> T	getValue(int colIndex)
<T> T	getValue(String colName)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicMessage

public BasicMessage(long offset,
                    String topic,
                    BasicAnyVector msg,
                    HashMap<String,Integer> nameToIndex)

BasicMessage

public BasicMessage(long offset,
                    String topic,
                    BasicAnyVector msg,
                    String sym)

Method Detail

getValue

public <T> T getValue(int colIndex)

Specified by:

getValue in interface IMessage

getValue

public <T> T getValue(String colName)

Specified by:

getValue in interface IMessage

getTopic

public String getTopic()

Specified by:

getTopic in interface IMessage

getOffset

public long getOffset()

Specified by:

getOffset in interface IMessage

getEntity

public Entity getEntity(int colIndex)

Specified by:

getEntity in interface IMessage

getMsg

public Entity getMsg()

size

public int size()

Specified by:

size in interface IMessage

getSym

public String getSym()