org.yamcs.web.websocket

Class ProtobufDecoder

java.lang.Object

org.yamcs.web.websocket.ProtobufDecoder

All Implemented Interfaces:

WebSocketDecoder

public class ProtobufDecoder
extends Object
implements WebSocketDecoder

Decodes an incoming web socket message using protobuf.

Constructor Summary

Constructors

Constructor and Description
ProtobufDecoder()

Method Summary

Modifier and Type	Method and Description
WebSocketDecodeContext	decodeMessage(InputStream in) Decodes the common wrapper fields of an incoming web socket message.
<T extends com.google.protobuf.MessageLite.Builder> T	decodeMessageData(WebSocketDecodeContext ctx, io.protostuff.Schema<T> dataSchema) Decodes any data that may be wrapped by the incoming web socket message

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtobufDecoder

public ProtobufDecoder()

Method Detail

decodeMessage

public WebSocketDecodeContext decodeMessage(InputStream in)
                                     throws WebSocketException

Description copied from interface: WebSocketDecoder

Decodes the common wrapper fields of an incoming web socket message. The actual data can be set implementation-specific and does not necessarily need to be processed here, since a second call will be made with an appropriately determined schema.

Specified by:

decodeMessage in interface WebSocketDecoder

Throws:

WebSocketException

decodeMessageData

public <T extends com.google.protobuf.MessageLite.Builder> T decodeMessageData(WebSocketDecodeContext ctx,
                                                                               io.protostuff.Schema<T> dataSchema)
                                                                        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