org.yamcs.web.websocket

Class JsonDecoder

java.lang.Object

org.yamcs.web.websocket.JsonDecoder

All Implemented Interfaces:

WebSocketDecoder

public class JsonDecoder
extends Object
implements WebSocketDecoder

Constructor Summary

Constructors

Constructor and Description
JsonDecoder()

Method Summary

Modifier and Type	Method and Description
WebSocketDecodeContext	decodeMessage(InputStream in) Decodes the first few common wrapper fields of an incoming web socket message. Sample: [1,1,2,{"<resource>":"<operation>", "data": <undecoded remainder>}]
<T extends com.google.protobuf.MessageLite.Builder> T	decodeMessageData(WebSocketDecodeContext ctx, io.protostuff.Schema<T> schema) Decodes any data that may be wrapped by the incoming web socket message
static void	main(String... args)
protected static void	requireTerminalToken(int requestId, com.fasterxml.jackson.core.JsonParser jsp, com.fasterxml.jackson.core.JsonToken token)
protected static void	requireToken(int requestId, com.fasterxml.jackson.core.JsonParser jsp, com.fasterxml.jackson.core.JsonToken token, String type)

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonDecoder

public JsonDecoder()

Method Detail

decodeMessage

public WebSocketDecodeContext decodeMessage(InputStream in)
                                     throws WebSocketException

Decodes the first few common wrapper fields of an incoming web socket message.
Sample: [1,1,2,{"<resource>":"<operation>", "data": <undecoded remainder>}]

Specified by:

decodeMessage in interface WebSocketDecoder

Throws:

WebSocketException

requireToken

protected static void requireToken(int requestId,
                                   com.fasterxml.jackson.core.JsonParser jsp,
                                   com.fasterxml.jackson.core.JsonToken token,
                                   String type)
                            throws IOException,
                                   WebSocketException

Throws:

IOException

WebSocketException

requireTerminalToken

protected static void requireTerminalToken(int requestId,
                                           com.fasterxml.jackson.core.JsonParser jsp,
                                           com.fasterxml.jackson.core.JsonToken token)
                                    throws IOException,
                                           WebSocketException

Throws:

IOException

WebSocketException

decodeMessageData

public <T extends com.google.protobuf.MessageLite.Builder> T decodeMessageData(WebSocketDecodeContext ctx,
                                                                               io.protostuff.Schema<T> schema)
                                                                        throws WebSocketException

Description copied from interface: WebSocketDecoder

Decodes any data that may be wrapped by the incoming web socket message

Specified by:

decodeMessageData in interface WebSocketDecoder

Throws:

WebSocketException

main

public static void main(String... args)
                 throws WebSocketException

Throws:

WebSocketException