public class ServerConnectionHandler extends AbstractServerConnectionHandler implements BrowserListener
Modifier and Type | Field and Description |
---|---|
static String |
VERSION |
connectionInformation, ioSession, messenger, pingService
Constructor and Description |
---|
ServerConnectionHandler(Service service,
IoSession ioSession,
ConnectionInformation connectionInformation) |
Modifier and Type | Method and Description |
---|---|
protected void |
acknowledge(Message message) |
protected void |
cleanUp() |
void |
dataChanged(List<BrowserEntry> addedOrUpdated,
Set<String> removed,
boolean full) |
void |
dataChangedConditions(String subscriptionId,
List<MonitorStatusInformation> addedOrUpdated,
Set<String> removed,
boolean full) |
void |
dataChangedEvents(String poolId,
List<Event> addedEvents) |
protected void |
handleCreateSessionComplete(Future<Session> future,
Message message,
Properties props) |
protected void |
queryClose(Message message) |
protected void |
queryCreate(Message message) |
protected void |
queryLoadMore(Message message) |
void |
sendQueryData(QueryImpl queryImpl,
List<Event> events) |
void |
sendQueryState(QueryImpl queryImpl,
QueryState state,
Throwable error) |
void |
statusChangedConditions(String subscriptionId,
SubscriptionState status) |
void |
statusChangedEvents(String poolId,
SubscriptionState status) |
protected void |
subscribeEventPool(Message message) |
protected void |
subscribeMonitors(Message message) |
protected void |
unsubscribeEventPool(Message message) |
protected void |
unsubscribeMonitors(Message message) |
exceptionCaught, getBooleanProperty, getIntProperty, getMessageTimeout, getPingPeriod, getTransportProperties, messageReceived, messageSent, modifyFilterChain, replySessionCreated, sendPrivilegeChange, sessionClosed, sessionConfigured, sessionCreated, sessionIdle, sessionOpened, startSession
public static final String VERSION
public ServerConnectionHandler(Service service, IoSession ioSession, ConnectionInformation connectionInformation)
protected void queryCreate(Message message)
protected void queryClose(Message message)
protected void queryLoadMore(Message message)
protected void acknowledge(Message message)
protected void subscribeEventPool(Message message)
protected void unsubscribeEventPool(Message message)
protected void subscribeMonitors(Message message)
protected void unsubscribeMonitors(Message message)
protected void handleCreateSessionComplete(Future<Session> future, Message message, Properties props)
protected void cleanUp()
cleanUp
in class AbstractServerConnectionHandler
public void statusChangedEvents(String poolId, SubscriptionState status)
public void dataChangedConditions(String subscriptionId, List<MonitorStatusInformation> addedOrUpdated, Set<String> removed, boolean full)
public void statusChangedConditions(String subscriptionId, SubscriptionState status)
public void dataChanged(List<BrowserEntry> addedOrUpdated, Set<String> removed, boolean full)
dataChanged
in interface BrowserListener
public void sendQueryState(QueryImpl queryImpl, QueryState state, Throwable error)