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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getName()
void
selectProcessor(Processor processor)
void
socketClosed()
Called when the web socket is closedvoid
streamRegistered(String instance, Stream stream)
void
streamUnregistered(String instance, String name)
void
streamUpdated(String instance, 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 interfaceWebSocketResource
-
subscribe
public WebSocketReply subscribe(WebSocketDecodeContext ctx, WebSocketDecoder decoder) throws WebSocketException
- Specified by:
subscribe
in interfaceWebSocketResource
- Throws:
WebSocketException
-
streamRegistered
public void streamRegistered(String instance, Stream stream)
- Specified by:
streamRegistered
in interfaceTableStreamListener
-
streamUpdated
public void streamUpdated(String instance, Table.StreamInfo stream)
- Specified by:
streamUpdated
in interfaceTableStreamListener
-
streamUnregistered
public void streamUnregistered(String instance, String name)
- Specified by:
streamUnregistered
in interfaceTableStreamListener
-
unsubscribe
public WebSocketReply unsubscribe(WebSocketDecodeContext ctx, WebSocketDecoder decoder) throws WebSocketException
- Specified by:
unsubscribe
in interfaceWebSocketResource
- Throws:
WebSocketException
-
selectProcessor
public void selectProcessor(Processor processor) throws ProcessorException
- Specified by:
selectProcessor
in interfaceWebSocketResource
- Throws:
ProcessorException
-
unselectProcessor
public void unselectProcessor()
- Specified by:
unselectProcessor
in interfaceWebSocketResource
-
socketClosed
public void socketClosed()
Description copied from interface:WebSocketResource
Called when the web socket is closed- Specified by:
socketClosed
in interfaceWebSocketResource
-
-