|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.edg.info.ConsumerConnection
Details of a single streaming connection to a consumer.
Constructor Summary | |
ConsumerConnection(java.nio.channels.SocketChannel socketChannel,
Expression where,
java.util.Vector select,
org.edg.info.system.StreamRequest request)
Creates a new ConsumerConnection object. |
Method Summary | |
int |
getConnectAttempts()
Gets the number of connection attempts. |
int |
getConnectionId()
Returns consumer connection ID |
java.nio.ByteBuffer |
getCurrentResultSetBytes()
Gets the serialized bytes for the current ResultSet. |
long |
getLastWriteDurationMillis()
Gets the duration of the last write. |
org.edg.info.system.StreamRequest |
getRequest()
Returns stream request. |
java.util.Vector |
getSelect()
Returns SELECT items. |
java.nio.channels.SocketChannel |
getSocketChannel()
Returns socket channel. |
java.lang.String |
getUrl()
Returns consumer URL. |
Expression |
getWhere()
Returns WHERE clause. |
void |
incConnectAttempts()
Increments the number of connection attempts by one. |
void |
resetConnectAttempts()
Resets the number of connection attempts to zero. |
void |
setCurrentResultSetBytes(java.nio.ByteBuffer bytes)
Sets the serialized bytes for the current ResultSet. |
void |
setLastWriteDurationMillis(long lastWriteDurationMS)
Sets the duration of the last write. |
void |
setSocketChannel(java.nio.channels.SocketChannel channel)
Sets socket channel. |
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
public ConsumerConnection(java.nio.channels.SocketChannel socketChannel, Expression where, java.util.Vector select, org.edg.info.system.StreamRequest request)
socketChannel
- Socket channel connected to consumer (or null
if not yet instantiated).where
- SQL WHERE clause.select
- SQL SELECT statement.request
- Consumer streaming details.Method Detail |
public java.nio.ByteBuffer getCurrentResultSetBytes()
public void setCurrentResultSetBytes(java.nio.ByteBuffer bytes)
bytes
- Serialized bytes for ResultSet in ByteBuffer.public int getConnectionId()
public org.edg.info.system.StreamRequest getRequest()
public java.util.Vector getSelect()
public void setSocketChannel(java.nio.channels.SocketChannel channel)
channel
- Socket channel.public java.nio.channels.SocketChannel getSocketChannel()
null
).public java.lang.String getUrl()
public Expression getWhere()
public java.lang.String toString()
Object.toString()
public int getConnectAttempts()
public void resetConnectAttempts()
public void incConnectAttempts()
public long getLastWriteDurationMillis()
public void setLastWriteDurationMillis(long lastWriteDurationMS)
lastWriteDurationMS
- Duration of the last write (in millis).
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |