public class ServerConnectionHandler extends AbstractServerConnectionHandler implements ItemListListener
Modifier and Type | Field and Description |
---|---|
static int |
MAX_DATA_SIZE |
static String |
VERSION |
connectionInformation, ioSession, messenger, pingService
Constructor and Description |
---|
ServerConnectionHandler(Service service,
org.apache.mina.core.session.IoSession ioSession,
ConnectionInformation connectionInformation) |
Modifier and Type | Method and Description |
---|---|
protected void |
cleanUp() |
protected void |
handleCloseQuery(Message message) |
protected void |
handleCreateQuery(Message message) |
protected void |
handleCreateSessionComplete(Future<Session> future,
Message message,
Properties props) |
protected void |
handleUpdateQueryParameters(Message message) |
void |
listChanged(Set<HistoricalItemInformation> addedOrModified,
Set<String> removed,
boolean full) |
void |
sendQueryData(long queryId,
int index,
Map<String,List<Double>> values,
List<ValueInformation> valueInformation) |
void |
sendQueryParameters(long queryId,
QueryParameters parameters,
Set<String> valueTypes) |
void |
sendQueryState(long queryId,
QueryState state) |
protected void |
setItemList(boolean flag) |
createDefaultContext, exceptionCaught, getBooleanProperty, getIntProperty, getMessageTimeout, getPingPeriod, getTransportProperties, messageReceived, messageSent, modifyFilterChain, replySessionCreated, sendPrivilegeChange, sessionClosed, sessionConfigured, sessionCreated, sessionIdle, sessionOpened, startSession
public static final String VERSION
public static final int MAX_DATA_SIZE
public ServerConnectionHandler(Service service, org.apache.mina.core.session.IoSession ioSession, ConnectionInformation connectionInformation)
protected void handleUpdateQueryParameters(Message message)
protected void handleCloseQuery(Message message)
protected void handleCreateQuery(Message message)
public void sendQueryData(long queryId, int index, Map<String,List<Double>> values, List<ValueInformation> valueInformation)
public void sendQueryParameters(long queryId, QueryParameters parameters, Set<String> valueTypes)
public void sendQueryState(long queryId, QueryState state)
protected void setItemList(boolean flag)
protected void handleCreateSessionComplete(Future<Session> future, Message message, Properties props)
protected void cleanUp()
cleanUp
in class AbstractServerConnectionHandler
public void listChanged(Set<HistoricalItemInformation> addedOrModified, Set<String> removed, boolean full)
listChanged
in interface ItemListListener