|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.ibm.websphere.samples.asynchbeans.wstrader.tickstream.StreamClientState
public class StreamClientState
Contains all logic for maintaining the state of a client (login id). Each ClientState has an associated Asynch Scope which is a child of the main Application Asynch Scope or StreamApplicationState.
Field Summary | |
---|---|
static java.lang.String |
SSM_CLIENT
|
Method Summary | |
---|---|
void |
destroy()
Destroy this instance. |
void |
destroyed(com.ibm.websphere.asynchbeans.AsynchScope scope)
|
void |
destroyed(com.ibm.websphere.asynchbeans.SubsystemMonitor ssm)
|
StreamListener |
findStreamer(java.lang.String name)
Find a streamer by it's name |
StreamApplicationState |
getApplicationState()
Gets the appState. |
com.ibm.websphere.asynchbeans.AsynchScope |
getClientAsynchScope()
Get the client Asynch Scope that is associated with this Client State |
java.lang.String |
getClientID()
Get the ID of the client that is associated with this Client State |
static StreamClientState |
getClientState(StreamApplicationState appState,
java.lang.String clientID,
boolean createFlag)
Create a StreamClientState instance for a specific client id and application state. |
void |
handleClientPing()
Handles pings from the Ping servlet for a given client |
void |
listenerCountChanged(com.ibm.websphere.asynchbeans.EventSource es,
int oldCount,
int newCount)
|
void |
listenerExceptionThrown(com.ibm.websphere.asynchbeans.EventSource es,
java.lang.Object listener,
java.lang.String methodName,
java.lang.Throwable exception)
|
void |
registerStreamer(StreamListener streamer)
A client can have multiple streaming connections concurrently. |
void |
setApplicationState(StreamApplicationState appState)
Sets the appState. |
void |
subsystemIsDead(com.ibm.websphere.asynchbeans.SubsystemMonitor ssm)
|
void |
subsystemIsFresh(com.ibm.websphere.asynchbeans.SubsystemMonitor ssm)
|
void |
subsystemIsStale(com.ibm.websphere.asynchbeans.SubsystemMonitor ssm)
|
java.lang.String |
toString()
|
void |
unexpectedException(com.ibm.websphere.asynchbeans.EventSource es,
java.lang.Object runnable,
java.lang.Throwable exception)
|
void |
unregisterStreamer(StreamListener streamer)
Unregister a streamer from the client state. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final java.lang.String SSM_CLIENT
Method Detail |
---|
public static StreamClientState getClientState(StreamApplicationState appState, java.lang.String clientID, boolean createFlag)
appState
- the associated StreamApplicationStateclientID
- the client id to associate with the StreamClientState.createFlag
- when true, create a new StreamClientState when one doesn't already exist.public void destroy()
public void destroyed(com.ibm.websphere.asynchbeans.AsynchScope scope)
destroyed
in interface com.ibm.websphere.asynchbeans.AsynchScopeEvents
AsynchScopeEvents.destroyed(AsynchScope)
public void destroyed(com.ibm.websphere.asynchbeans.SubsystemMonitor ssm)
destroyed
in interface com.ibm.websphere.asynchbeans.SubsystemMonitorEvents
SubsystemMonitorEvents.destroyed(SubsystemMonitor)
public void subsystemIsDead(com.ibm.websphere.asynchbeans.SubsystemMonitor ssm)
subsystemIsDead
in interface com.ibm.websphere.asynchbeans.SubsystemMonitorEvents
SubsystemMonitorEvents.subsystemIsDead(SubsystemMonitor)
public void subsystemIsFresh(com.ibm.websphere.asynchbeans.SubsystemMonitor ssm)
subsystemIsFresh
in interface com.ibm.websphere.asynchbeans.SubsystemMonitorEvents
SubsystemMonitorEvents.subsystemIsFresh(SubsystemMonitor)
public void subsystemIsStale(com.ibm.websphere.asynchbeans.SubsystemMonitor ssm)
subsystemIsStale
in interface com.ibm.websphere.asynchbeans.SubsystemMonitorEvents
SubsystemMonitorEvents.subsystemIsStale(SubsystemMonitor)
public void listenerCountChanged(com.ibm.websphere.asynchbeans.EventSource es, int oldCount, int newCount)
listenerCountChanged
in interface com.ibm.websphere.asynchbeans.EventSourceEvents
EventSourceEvents.listenerCountChanged(EventSource, int, int)
public void listenerExceptionThrown(com.ibm.websphere.asynchbeans.EventSource es, java.lang.Object listener, java.lang.String methodName, java.lang.Throwable exception)
listenerExceptionThrown
in interface com.ibm.websphere.asynchbeans.EventSourceEvents
EventSourceEvents.listenerExceptionThrown(EventSource, Object, String, Throwable)
public void unexpectedException(com.ibm.websphere.asynchbeans.EventSource es, java.lang.Object runnable, java.lang.Throwable exception)
unexpectedException
in interface com.ibm.websphere.asynchbeans.EventSourceEvents
EventSourceEvents.unexpectedException(EventSource, Object, Throwable)
public void handleClientPing()
public java.lang.String getClientID()
public com.ibm.websphere.asynchbeans.AsynchScope getClientAsynchScope()
public StreamApplicationState getApplicationState()
public void setApplicationState(StreamApplicationState appState)
appState
- The appState to setpublic void registerStreamer(StreamListener streamer)
streamer
- The streamer to register.public void unregisterStreamer(StreamListener streamer)
streamer
- The streamer to unregister.public StreamListener findStreamer(java.lang.String name)
name
- The streamer name.public java.lang.String toString()
toString
in class java.lang.Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |