Package org.yamcs.http.websocket

Class StreamsResource

java.lang.Object

org.yamcs.http.websocket.StreamsResource

All Implemented Interfaces:

WebSocketResource, TableStreamListener

public class StreamsResource
extends Object
implements WebSocketResource, TableStreamListener

Emits info updates on stream stats

Constructor Summary

Constructors

Constructor	Description
StreamsResource(ConnectedWebSocketClient client)

Method Summary

Modifier and Type	Method	Description
String	getName()
void	selectProcessor(Processor processor)
void	socketClosed()	Called when the web socket is closed
void	streamRegistered(String instance, Stream stream)
void	streamUnregistered(String instance, String name)
void	streamUpdated(String instance, org.yamcs.protobuf.Table.StreamInfo stream)
WebSocketReply	subscribe(WebSocketDecodeContext ctx, WebSocketDecoder decoder)
void	unselectProcessor()
WebSocketReply	unsubscribe(WebSocketDecodeContext ctx, WebSocketDecoder decoder)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.yamcs.management.TableStreamListener

tableRegistered, tableUnregistered

Methods inherited from interface org.yamcs.http.websocket.WebSocketResource

processRequest, subscribe, subscribeAll, unsubscribeAll

Constructor Detail

StreamsResource

public StreamsResource(ConnectedWebSocketClient client)

Method Detail

getName

public String getName()

Specified by:

getName in interface WebSocketResource

subscribe

public WebSocketReply subscribe(WebSocketDecodeContext ctx,
                                WebSocketDecoder decoder)
                         throws WebSocketException

Specified by:

subscribe in interface WebSocketResource

Throws:

WebSocketException

streamRegistered

public void streamRegistered(String instance,
                             Stream stream)

Specified by:

streamRegistered in interface TableStreamListener

streamUpdated

public void streamUpdated(String instance,
                          org.yamcs.protobuf.Table.StreamInfo stream)

Specified by:

streamUpdated in interface TableStreamListener

streamUnregistered

public void streamUnregistered(String instance,
                               String name)

Specified by:

streamUnregistered in interface TableStreamListener

unsubscribe

public WebSocketReply unsubscribe(WebSocketDecodeContext ctx,
                                  WebSocketDecoder decoder)
                           throws WebSocketException

Specified by:

unsubscribe in interface WebSocketResource

Throws:

WebSocketException

selectProcessor

public void selectProcessor(Processor processor)
                     throws ProcessorException

Specified by:

selectProcessor in interface WebSocketResource

Throws:

ProcessorException

unselectProcessor

public void unselectProcessor()

Specified by:

unselectProcessor in interface WebSocketResource

socketClosed

public void socketClosed()

Description copied from interface: WebSocketResource

Called when the web socket is closed

Specified by:

socketClosed in interface WebSocketResource