org.edg.info
Class ConsumerConnection

java.lang.Object
  extended byorg.edg.info.ConsumerConnection

public class ConsumerConnection
extends java.lang.Object

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)
          Constructor.
 
Method Summary
 int getConnectAttempts()
           
 int getConnectionId()
          Returns consumer connection ID
 long getLastWriteDurationMillis()
           
 org.edg.info.system.StreamRequest getRequest()
          Returns stream request.
 java.util.Vector getSelect()
          Returns SELECT statement
 java.nio.channels.SocketChannel getSocketChannel()
          Returns socket channel
 java.lang.String getUrl()
          Returns consumer URL
 Expression getWhere()
          Returns WHERE clause
 void incConnectAttempts()
           
 void resetConnectAttempts()
           
 void setLastWriteDurationMillis(long lastWriteDurationMS)
           
 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

ConsumerConnection

public ConsumerConnection(java.nio.channels.SocketChannel socketChannel,
                          Expression where,
                          java.util.Vector select,
                          org.edg.info.system.StreamRequest request)
Constructor.

Parameters:
socketChannel -
where - WHERE clause
select - SELECT statement
request - Consumer URL
Method Detail

getConnectionId

public int getConnectionId()
Returns consumer connection ID

Returns:

getRequest

public org.edg.info.system.StreamRequest getRequest()
Returns stream request.

Returns:

getSelect

public java.util.Vector getSelect()
Returns SELECT statement

Returns:

setSocketChannel

public void setSocketChannel(java.nio.channels.SocketChannel channel)
Sets socket channel.

Parameters:
channel -

getSocketChannel

public java.nio.channels.SocketChannel getSocketChannel()
Returns socket channel

Returns:

getUrl

public java.lang.String getUrl()
Returns consumer URL

Returns:

getWhere

public Expression getWhere()
Returns WHERE clause

Returns:

toString

public java.lang.String toString()

getConnectAttempts

public int getConnectAttempts()

resetConnectAttempts

public void resetConnectAttempts()

incConnectAttempts

public void incConnectAttempts()

getLastWriteDurationMillis

public long getLastWriteDurationMillis()

setLastWriteDurationMillis

public void setLastWriteDurationMillis(long lastWriteDurationMS)