org.yamcs.ui

Class ProcessorControlClient

java.lang.Object

org.yamcs.ui.ProcessorControlClient

All Implemented Interfaces:

EventListener, ConnectionListener, WebSocketClientCallback, WebSocketResponseHandler

public class ProcessorControlClient
extends Object
implements ConnectionListener, WebSocketClientCallback, WebSocketResponseHandler

controls processors in yamcs server via websocket

Author:

nm

Constructor Summary

Constructors

Constructor and Description
ProcessorControlClient(YamcsConnector yconnector)

Method Summary

Modifier and Type	Method and Description
void	connected(String url)
void	connecting(String url)
void	connectionFailed(String url, YamcsException exception)
CompletableFuture<Void>	connectToProcessor(String instance, String processorName, int[] clients)
CompletableFuture<byte[]>	createProcessor(String instance, String name, String type, Yamcs.ReplayRequest spec, boolean persistent, int[] clients)
void	destroyProcessor(String name)
void	disconnected()
void	log(String message)
void	onException(Web.WebSocketServerMessage.WebSocketExceptionData e)
void	onMessage(Web.WebSocketServerMessage.WebSocketSubscriptionData data)
void	pauseArchiveReplay(String instance, String name)
void	receiveInitialConfig()
void	resumeArchiveReplay(String instance, String name)
void	seekArchiveReplay(String instance, String name, long newPosition)
void	setProcessorListener(ProcessorListener yamcsMonitor)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.yamcs.api.ws.WebSocketClientCallback

connected, connectionFailed, onInvalidIdentification

Methods inherited from interface org.yamcs.api.ws.WebSocketResponseHandler

onCompletion

Constructor Detail

ProcessorControlClient

public ProcessorControlClient(YamcsConnector yconnector)

Method Detail

setProcessorListener

public void setProcessorListener(ProcessorListener yamcsMonitor)

destroyProcessor

public void destroyProcessor(String name)
                      throws YamcsApiException

Throws:

YamcsApiException

createProcessor

public CompletableFuture<byte[]> createProcessor(String instance,
                                                 String name,
                                                 String type,
                                                 Yamcs.ReplayRequest spec,
                                                 boolean persistent,
                                                 int[] clients)
                                          throws YamcsException,
                                                 YamcsApiException

Throws:

YamcsException

YamcsApiException

connectToProcessor

public CompletableFuture<Void> connectToProcessor(String instance,
                                                  String processorName,
                                                  int[] clients)
                                           throws YamcsException,
                                                  YamcsApiException

Throws:

YamcsException

YamcsApiException

pauseArchiveReplay

public void pauseArchiveReplay(String instance,
                               String name)
                        throws YamcsException,
                               YamcsApiException

Throws:

YamcsException

YamcsApiException

resumeArchiveReplay

public void resumeArchiveReplay(String instance,
                                String name)
                         throws YamcsApiException,
                                YamcsException

Throws:

YamcsApiException

YamcsException

seekArchiveReplay

public void seekArchiveReplay(String instance,
                              String name,
                              long newPosition)
                       throws YamcsApiException,
                              YamcsException

Throws:

YamcsApiException

YamcsException

connecting

public void connecting(String url)

Specified by:

connecting in interface ConnectionListener

receiveInitialConfig

public void receiveInitialConfig()

connected

public void connected(String url)

Specified by:

connected in interface ConnectionListener

onMessage

public void onMessage(Web.WebSocketServerMessage.WebSocketSubscriptionData data)

Specified by:

onMessage in interface WebSocketClientCallback

connectionFailed

public void connectionFailed(String url,
                             YamcsException exception)

Specified by:

connectionFailed in interface ConnectionListener

disconnected

public void disconnected()

Specified by:

disconnected in interface ConnectionListener

Specified by:

disconnected in interface WebSocketClientCallback

log

public void log(String message)

Specified by:

log in interface ConnectionListener

onException

public void onException(Web.WebSocketServerMessage.WebSocketExceptionData e)

Specified by:

onException in interface WebSocketResponseHandler