edu.umass.cs.nio

Class MessageExtractor

java.lang.Object

edu.umass.cs.nio.MessageExtractor

All Implemented Interfaces:

DataProcessingWorker, InterfaceMessageExtractor

public class MessageExtractor
extends java.lang.Object
implements InterfaceMessageExtractor

Author:

V. Arun This class is a legacy of an old design and currently does not do very much except for taking bytes from NIO and handing them over to a suitable packet demultiplexer. Earlier, this class used to have functionality for parsing the header and payload by buffering the incoming bytestream by converting it first into a character stream. This was ugly and the header functionality has now been integrated into NIOTransport for all messages including byte[].

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	STRINGIFIED

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MessageExtractor()
protected	MessageExtractor(AbstractPacketDemultiplexer<?> pd)

Method Summary

Modifier and Type	Method and Description
void	addPacketDemultiplexer(AbstractPacketDemultiplexer<?> pd) Note: Use with care.
static java.lang.String	decode(byte[] bytes)
static java.lang.String	decode(byte[] bytes, int offset, int length)
void	demultiplexMessage(java.lang.Object message)
protected static void	fatalExit(java.io.UnsupportedEncodingException e)
protected static org.json.JSONObject	parseJSON(java.lang.String msg)
protected static org.json.JSONObject	parseJSON(java.lang.String msg, boolean cacheStringified) String to JSON conversion
static net.minidev.json.JSONObject	parseJSONSmart(java.lang.String msg)
void	precedePacketDemultiplexer(AbstractPacketDemultiplexer<?> pd) Note: Use with care.
void	processData(java.nio.channels.SocketChannel socket, java.nio.ByteBuffer incoming) Incoming data has to be associated with a socket channel, not a nodeID, because the sending node's id is not known until the message is parsed.
void	processLocalMessage(java.net.InetSocketAddress sockAddr, byte[] msg)
static org.json.JSONObject	stampAddressIntoJSONObject(java.net.InetSocketAddress sndrAddress, java.net.InetSocketAddress rcvrAddress, org.json.JSONObject json)
static net.minidev.json.JSONObject	stampAddressIntoJSONObject(java.net.InetSocketAddress sndrAddress, java.net.InetSocketAddress rcvrAddress, net.minidev.json.JSONObject json) For comparing json-smart with org.json.
void	stop()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

STRINGIFIED

public static final java.lang.String STRINGIFIED

See Also:

Constant Field Values

Constructor Detail

MessageExtractor

protected MessageExtractor(AbstractPacketDemultiplexer<?> pd)

MessageExtractor

protected MessageExtractor()

Method Detail

addPacketDemultiplexer

public void addPacketDemultiplexer(AbstractPacketDemultiplexer<?> pd)

Note: Use with care. This will change demultiplexing behavior midway, which is usually not what you want to do. This is typically useful to set in the beginning.

Specified by:

addPacketDemultiplexer in interface InterfaceMessageExtractor

precedePacketDemultiplexer

public void precedePacketDemultiplexer(AbstractPacketDemultiplexer<?> pd)

Note: Use with care. This will change demultiplexing behavior midway, which is usually not what you want to do. This is typically useful to set in the beginning.

Specified by:

precedePacketDemultiplexer in interface InterfaceMessageExtractor

processData

public void processData(java.nio.channels.SocketChannel socket,
                        java.nio.ByteBuffer incoming)

Incoming data has to be associated with a socket channel, not a nodeID, because the sending node's id is not known until the message is parsed. This means that, if the the socket channel changes in the middle of the transmission, that message will **definitely** be lost.

Specified by:

processData in interface DataProcessingWorker

Parameters:

socket - The socket channel on which the bytes were received.

incoming - The bytes received.

stop

public void stop()

Specified by:

stop in interface InterfaceMessageExtractor

processLocalMessage

public void processLocalMessage(java.net.InetSocketAddress sockAddr,
                                byte[] msg)

Specified by:

processLocalMessage in interface InterfaceMessageExtractor

parseJSON

protected static final org.json.JSONObject parseJSON(java.lang.String msg,
                                                     boolean cacheStringified)

String to JSON conversion

Parameters:

msg -

Returns:

parseJSON

protected static final org.json.JSONObject parseJSON(java.lang.String msg)

parseJSONSmart

public static final net.minidev.json.JSONObject parseJSONSmart(java.lang.String msg)

Parameters:

msg -

Returns:

Parsed JSON.

fatalExit

protected static final void fatalExit(java.io.UnsupportedEncodingException e)

decode

public static final java.lang.String decode(byte[] bytes)
                                     throws java.io.UnsupportedEncodingException

Parameters:

bytes -

Returns:

String decoded from bytes.

Throws:

java.io.UnsupportedEncodingException

decode

public static final java.lang.String decode(byte[] bytes,
                                            int offset,
                                            int length)
                                     throws java.io.UnsupportedEncodingException

Parameters:

bytes -

offset -

length -

Returns:

String decoded from bytes.

Throws:

java.io.UnsupportedEncodingException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

demultiplexMessage

public void demultiplexMessage(java.lang.Object message)

Specified by:

demultiplexMessage in interface DataProcessingWorker

Specified by:

demultiplexMessage in interface InterfaceMessageExtractor

stampAddressIntoJSONObject

public static final org.json.JSONObject stampAddressIntoJSONObject(java.net.InetSocketAddress sndrAddress,
                                                                   java.net.InetSocketAddress rcvrAddress,
                                                                   org.json.JSONObject json)

Parameters:

sndrAddress -

rcvrAddress -

json -

Returns:

JSONObject with addresses stamped.

stampAddressIntoJSONObject

public static final net.minidev.json.JSONObject stampAddressIntoJSONObject(java.net.InetSocketAddress sndrAddress,
                                                                           java.net.InetSocketAddress rcvrAddress,
                                                                           net.minidev.json.JSONObject json)

For comparing json-smart with org.json.

Parameters:

sndrAddress -

rcvrAddress -

json -

Returns:

Parsed JSON object.