Package org.eclipse.jetty.ee9.websocket.common

Class SessionTracker

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.ee9.websocket.common.SessionTracker

All Implemented Interfaces:

WebSocketSessionListener, Dumpable, Graceful, LifeCycle

public class SessionTracker
extends AbstractLifeCycle
implements WebSocketSessionListener, Graceful, Dumpable

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener, AbstractLifeCycle.StopException

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable

Dumpable.DumpableContainer

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Graceful

Graceful.Shutdown, Graceful.ThrowingRunnable

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

LifeCycle.Listener

Field Summary

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface org.eclipse.jetty.util.component.Dumpable

KEY

Constructor Summary

Constructors

Constructor	Description
SessionTracker()

Method Summary

Modifier and Type	Method	Description
protected void	doStart()	Method to override to start the lifecycle
protected void	doStop()	Method to override to stop the lifecycle
void	dump(Appendable out, String indent)	Dump this object (and children) into an Appendable using the provided indent after any new lines.
int	getNumSessions()
Collection<Session>	getSessions()
boolean	isShutdown()
void	onWebSocketSessionClosed(Session session)
void	onWebSocketSessionOpened(Session session)
CompletableFuture<Void>	shutdown()	Shutdown the component.

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

addEventListener, getEventListeners, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeEventListener, setEventListeners, start, stop, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dump, dumpSelf

Methods inherited from interface org.eclipse.jetty.ee9.websocket.api.WebSocketSessionListener

onWebSocketSessionCreated

Constructor Details

SessionTracker

public SessionTracker()

Method Details

getSessions

public Collection<Session> getSessions()

onWebSocketSessionOpened

public void onWebSocketSessionOpened(Session session)

Specified by:

onWebSocketSessionOpened in interface WebSocketSessionListener

onWebSocketSessionClosed

public void onWebSocketSessionClosed(Session session)

Specified by:

onWebSocketSessionClosed in interface WebSocketSessionListener

doStart

protected void doStart()
                throws Exception

Description copied from class: AbstractLifeCycle

Method to override to start the lifecycle

Overrides:

doStart in class AbstractLifeCycle

Throws:

AbstractLifeCycle.StopException - If thrown, the lifecycle will immediately be stopped.

Exception - If there was a problem starting. Will cause a transition to FAILED state

doStop

protected void doStop()
               throws Exception

Description copied from class: AbstractLifeCycle

Method to override to stop the lifecycle

Overrides:

doStop in class AbstractLifeCycle

Throws:

Exception - If there was a problem stopping. Will cause a transition to FAILED state

shutdown

public CompletableFuture<Void> shutdown()

Description copied from interface: Graceful

Shutdown the component. When this method returns, the component should not accept any new load.

Specified by:

shutdown in interface Graceful

Returns:

A future that is completed once all load on the component is completed

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface Graceful

Returns:

True if Graceful.shutdown() has been called.

getNumSessions

@ManagedAttribute("Total number of active WebSocket Sessions")
public int getNumSessions()

dump

public void dump(Appendable out,
 String indent)
          throws IOException

Description copied from interface: Dumpable

Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped.

Specified by:

dump in interface Dumpable

Parameters:

out - The appendable to dump to

indent - The indent to apply after any new lines.

Throws:

IOException - if unable to write to Appendable