Package org.yamcs.http.websocket

Class ConnectedWebSocketClient

java.lang.Object

org.yamcs.ConnectedClient

org.yamcs.http.websocket.ConnectedWebSocketClient

public class ConnectedWebSocketClient
extends ConnectedClient

Runs on the server side and oversees the life cycle of a client web socket connection. Combines multiple types of subscriptions to keep them bundled as one client session.

Constructor Summary

Constructors

Constructor	Description
ConnectedWebSocketClient(User user, String applicationName, String address, Processor processor, LegacyWebSocketFrameHandler wsHandler)

Method Summary

Modifier and Type	Method	Description
void	processorQuit()	Called when the processor is closing down
<T extends com.google.protobuf.Message> void	sendData(org.yamcs.protobuf.Yamcs.ProtoDataType dataType, T data)
void	sendReply(WebSocketReply reply)
void	setProcessor(Processor newProcessor)	Select or change the processor for this client.
void	socketClosed()

Methods inherited from class org.yamcs.ConnectedClient

getAddress, getApplicationName, getId, getLoginTime, getProcessor, getUser, setClientId

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectedWebSocketClient

public ConnectedWebSocketClient(User user,
                                String applicationName,
                                String address,
                                Processor processor,
                                LegacyWebSocketFrameHandler wsHandler)

Method Detail

setProcessor

public void setProcessor(Processor newProcessor)
                  throws ProcessorException

Description copied from class: ConnectedClient

Select or change the processor for this client.

Overrides:

setProcessor in class ConnectedClient

Parameters:

newProcessor - the processor to select

Throws:

ProcessorException

sendReply

public void sendReply(WebSocketReply reply)

sendData

public <T extends com.google.protobuf.Message> void sendData(org.yamcs.protobuf.Yamcs.ProtoDataType dataType,
                                                             T data)

processorQuit

public void processorQuit()

Description copied from class: ConnectedClient

Called when the processor is closing down

Overrides:

processorQuit in class ConnectedClient

socketClosed

public void socketClosed()