com.zfabrik.impl.workers

Class MessageExchange

java.lang.Object

com.zfabrik.impl.workers.MessageExchange

public class MessageExchange
extends Object

abstracts our communication model: Messages are pushed in from a stream and sent out to a stream. We use tickets to associates requests and responses. We do usually end up having a construction like this:

• StreamReader -(feed)->
  • StreamEventHandler -(feed)->
    • MessageExchange -(feed)->
      • MessageHandler

Field Summary

Fields

Modifier and Type	Field and Description
static String	BOUNDARY
static int	BOUNDARY_LENGTH
static String	ERROR
static String	TICKET
static String	TIMEOUT
static String	TYPE
static String	TYPE_M
static String	TYPE_R

Constructor Summary

Constructors

Constructor and Description
MessageExchange(Logger logger, IMessageHandler handler, IThreadPool tp, OutputStream out)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
static Map<String,Serializable>	decodeMessage(byte[] in)
static void	encodeMessage(OutputStream out, Map<String,Serializable> args)
int	getMaxQueueSize()
String	processLine(String line) process a line of input.
Map<String,Serializable>	sendMessage(Map<String,Serializable> msg, long timeout) Send a message and wait for a response with a timeout.

Methods inherited from class java.lang.Object

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

Field Detail

ERROR

public static final String ERROR

TYPE

public static final String TYPE

TYPE_R

public static final String TYPE_R

See Also:

Constant Field Values

TYPE_M

public static final String TYPE_M

See Also:

Constant Field Values

TICKET

public static final String TICKET

TIMEOUT

public static final String TIMEOUT

BOUNDARY

public static final String BOUNDARY

See Also:

Constant Field Values

BOUNDARY_LENGTH

public static final int BOUNDARY_LENGTH

Constructor Detail

MessageExchange

public MessageExchange(Logger logger,
               IMessageHandler handler,
               IThreadPool tp,
               OutputStream out)

Method Detail

processLine

public String processLine(String line)
                   throws IOException

process a line of input. Returns parts of the line that is not message (or null if none at all).

Throws:

IOException

sendMessage

public Map<String,Serializable> sendMessage(Map<String,Serializable> msg,
                                   long timeout)
                                     throws IOException,
                                            RemoteException

Send a message and wait for a response with a timeout. In case an fault is returned via the payload, it will be de-seriarlized, wrapped by a remote exception and thrown again by this method. Any other exception indicates a potentially critical communication error.

Parameters:

args -

Returns:

Throws:

IOException

RemoteException

encodeMessage

public static void encodeMessage(OutputStream out,
                 Map<String,Serializable> args)
                          throws IOException

Throws:

IOException

decodeMessage

public static Map<String,Serializable> decodeMessage(byte[] in)
                                              throws IOException

Throws:

IOException

getMaxQueueSize

public int getMaxQueueSize()

close

public void close()