Class TrackingWireCodec

java.lang.Object

io.fluxzero.common.api.tracking.TrackingWireCodec

public final class TrackingWireCodec
extends Object

Compact binary websocket representation for message publication and tracking.

The codec changes only the transport representation. Individual requests, messages, request identifiers, positions and response timings remain intact. Unsupported or heterogeneous values are left to the regular websocket transport codec.

Method Summary

Modifier and Type	Method	Description
static JsonType	tryDecode(byte[] bytes)	Decodes this codec's representation, or returns null for another transport representation.
static byte[]	tryEncode(JsonType value)	Encodes a supported tracking value, or returns null when the regular codec should be used.
static byte[]	tryEncode(JsonType value, boolean routedEnvelopes)	Encodes routed native envelopes only for a peer that explicitly supports them.

Methods inherited from class Object

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

Method Details

tryEncode

public static byte[] tryEncode(JsonType value)
                        throws IOException

Encodes a supported tracking value, or returns null when the regular codec should be used.

Throws:

IOException

tryEncode

public static byte[] tryEncode(JsonType value,
 boolean routedEnvelopes)
                        throws IOException

Encodes routed native envelopes only for a peer that explicitly supports them.

Throws:

IOException

tryDecode

public static JsonType tryDecode(byte[] bytes)
                          throws IOException

Decodes this codec's representation, or returns null for another transport representation.

Throws:

IOException