public class DefaultNetStreamDecoder extends java.lang.Object implements NetStreamDecoder
Modifier and Type | Field and Description |
---|---|
protected ThreadProxyPipe |
currentStream
The current pipe commands are being written to.
|
protected boolean |
debug
Show debugging messages.
|
protected java.util.HashMap<java.lang.String,ThreadProxyPipe> |
streams
Pairs (key,value) where the key is the listener ID and the value the MBox
of the listener.
|
Constructor and Description |
---|
DefaultNetStreamDecoder() |
Modifier and Type | Method and Description |
---|---|
protected void |
debug(java.lang.String message,
java.lang.Object... data) |
void |
decodeMessage(java.io.InputStream in)
Decode one message.
|
ThreadProxyPipe |
getDefaultStream()
Gives the default stream (a ThreadProxyPipe) identified with the name
"default".
|
ThreadProxyPipe |
getStream(java.lang.String name)
Gives the stream (a ThreadProxyPipe) identified with this name.
|
protected java.lang.Object[] |
readArray(java.io.InputStream in) |
protected java.lang.Boolean |
readBoolean(java.io.InputStream in) |
protected java.lang.Boolean[] |
readBooleanArray(java.io.InputStream in) |
protected java.lang.Byte |
readByte(java.io.InputStream in) |
protected java.lang.Byte[] |
readByteArray(java.io.InputStream in) |
protected java.lang.Double |
readDouble(java.io.InputStream in) |
protected java.lang.Double[] |
readDoubleArray(java.io.InputStream in) |
protected java.lang.Float |
readFloat(java.io.InputStream in) |
protected java.lang.Float[] |
readFloatArray(java.io.InputStream in) |
protected java.lang.Integer |
readInt(java.io.InputStream in) |
protected java.lang.Integer[] |
readIntArray(java.io.InputStream in) |
protected java.lang.Long |
readLong(java.io.InputStream in) |
protected java.lang.Long[] |
readLongArray(java.io.InputStream in) |
protected java.lang.Short |
readShort(java.io.InputStream in) |
protected java.lang.Short[] |
readShortArray(java.io.InputStream in) |
protected java.lang.String |
readString(java.io.InputStream in) |
protected int |
readType(java.io.InputStream in) |
protected long |
readUnsignedVarint(java.io.InputStream in) |
protected java.lang.Object |
readValue(java.io.InputStream in,
int valueType) |
protected long |
readVarint(java.io.InputStream in) |
void |
register(java.lang.String name,
ThreadProxyPipe stream)
Register a stream.
|
protected void |
serve_DEL_NODE(java.io.InputStream in) |
protected void |
serve_EVENT_ADD_EDGE_ATTR(java.io.InputStream in) |
protected void |
serve_EVENT_ADD_EDGE(java.io.InputStream in) |
protected void |
serve_EVENT_ADD_GRAPH_ATTR(java.io.InputStream in) |
protected void |
serve_EVENT_ADD_NODE_ATTR(java.io.InputStream in) |
protected void |
serve_EVENT_ADD_NODE(java.io.InputStream in) |
protected void |
serve_EVENT_CHG_EDGE_ATTR(java.io.InputStream in) |
protected void |
serve_EVENT_CHG_GRAPH_ATTR(java.io.InputStream in) |
protected void |
serve_EVENT_CHG_NODE_ATTR(java.io.InputStream in) |
protected void |
serve_EVENT_CLEARED(java.io.InputStream in) |
protected void |
serve_EVENT_DEL_EDGE_ATTR(java.io.InputStream in) |
protected void |
serve_EVENT_DEL_EDGE(java.io.InputStream in) |
protected void |
serve_EVENT_DEL_GRAPH_ATTR(java.io.InputStream in) |
protected void |
serve_EVENT_DEL_NODE_ATTR(java.io.InputStream in) |
protected void |
serve_EVENT_STEP(java.io.InputStream in) |
void |
setDebugOn(boolean on)
Enable or disable debugging.
|
protected boolean debug
protected ThreadProxyPipe currentStream
protected java.util.HashMap<java.lang.String,ThreadProxyPipe> streams
register(String,ThreadProxyPipe)
public ThreadProxyPipe getStream(java.lang.String name)
NetStreamDecoder
getStream
in interface NetStreamDecoder
name
- Identifier of the stream.public ThreadProxyPipe getDefaultStream()
NetStreamDecoder
getDefaultStream
in interface NetStreamDecoder
public void register(java.lang.String name, ThreadProxyPipe stream) throws java.lang.Exception
NetStreamDecoder
register
in interface NetStreamDecoder
name
- Filter only message with this name to the given message box.stream
- The ThreadProxyPipe to push the events to.java.lang.Exception
- If another Pipe is already registered at the given name.public void decodeMessage(java.io.InputStream in) throws java.io.IOException
NetStreamDecoder
decodeMessage
in interface NetStreamDecoder
java.io.IOException
protected void serve_EVENT_DEL_EDGE_ATTR(java.io.InputStream in)
in
- NetStreamConstants.EVENT_DEL_EDGE
protected void serve_EVENT_CHG_EDGE_ATTR(java.io.InputStream in)
NetStreamConstants.EVENT_CHG_EDGE_ATTR
protected void serve_EVENT_ADD_EDGE_ATTR(java.io.InputStream in)
NetStreamConstants.EVENT_ADD_EDGE_ATTR
protected void serve_EVENT_DEL_NODE_ATTR(java.io.InputStream in)
NetStreamConstants.EVENT_DEL_NODE_ATTR
protected void serve_EVENT_CHG_NODE_ATTR(java.io.InputStream in)
NetStreamConstants.EVENT_CHG_NODE_ATTR
protected void serve_EVENT_ADD_NODE_ATTR(java.io.InputStream in)
NetStreamConstants.EVENT_ADD_NODE_ATTR
protected void serve_EVENT_DEL_GRAPH_ATTR(java.io.InputStream in)
NetStreamConstants.EVENT_DEL_GRAPH_ATTR
protected void serve_EVENT_CHG_GRAPH_ATTR(java.io.InputStream in)
NetStreamConstants.EVENT_CHG_GRAPH_ATTR
protected void serve_EVENT_ADD_GRAPH_ATTR(java.io.InputStream in)
NetStreamConstants.EVENT_ADD_GRAPH_ATTR
protected void serve_EVENT_CLEARED(java.io.InputStream in)
NetStreamConstants.EVENT_CLEARED
protected void serve_EVENT_STEP(java.io.InputStream in)
NetStreamConstants.EVENT_STEP
protected void serve_EVENT_DEL_EDGE(java.io.InputStream in)
NetStreamConstants.EVENT_DEL_EDGE
protected void serve_EVENT_ADD_EDGE(java.io.InputStream in)
NetStreamConstants.EVENT_ADD_EDGE
protected void serve_DEL_NODE(java.io.InputStream in)
NetStreamConstants.DEL_NODE
protected void serve_EVENT_ADD_NODE(java.io.InputStream in)
NetStreamConstants.EVENT_ADD_NODE
protected int readType(java.io.InputStream in)
in
- protected java.lang.Object readValue(java.io.InputStream in, int valueType)
protected java.lang.Object[] readArray(java.io.InputStream in)
in
- protected java.lang.String readString(java.io.InputStream in)
protected java.lang.Boolean readBoolean(java.io.InputStream in)
protected java.lang.Byte readByte(java.io.InputStream in)
protected long readUnsignedVarint(java.io.InputStream in)
protected long readVarint(java.io.InputStream in)
protected java.lang.Short readShort(java.io.InputStream in)
protected java.lang.Integer readInt(java.io.InputStream in)
protected java.lang.Long readLong(java.io.InputStream in)
protected java.lang.Float readFloat(java.io.InputStream in)
protected java.lang.Double readDouble(java.io.InputStream in)
protected java.lang.Integer[] readIntArray(java.io.InputStream in)
in
- java.io.IOException
protected java.lang.Boolean[] readBooleanArray(java.io.InputStream in)
protected java.lang.Byte[] readByteArray(java.io.InputStream in)
protected java.lang.Double[] readDoubleArray(java.io.InputStream in)
protected java.lang.Float[] readFloatArray(java.io.InputStream in)
protected java.lang.Long[] readLongArray(java.io.InputStream in)
protected java.lang.Short[] readShortArray(java.io.InputStream in)
protected void debug(java.lang.String message, java.lang.Object... data)
public void setDebugOn(boolean on)
NetStreamDecoder
setDebugOn
in interface NetStreamDecoder