rina.ipcProcess.util
Class MessageQueue

java.lang.Object
  rina.ipcProcess.util.MessageQueue

public class MessageQueue
extends java.lang.Object

Constructor Summary

MessageQueue()
Constructor

Method Summary

void	addReceive(byte[] data) add a message to the queue of received message
void	addSend(byte[] data) add a message to the queue of sent messages
byte[]	getReceive()
java.util.Queue<byte[]>	getReceiveQueue()
byte[]	getSend()
java.util.Queue<byte[]>	getSendQueue()
void	setReceiveQueue(java.util.Queue<byte[]> receiveQueue)
void	setSendQueue(java.util.Queue<byte[]> sendQueue)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageQueue

public MessageQueue()

Constructor

Method Detail

addReceive

public void addReceive(byte[] data)

add a message to the queue of received message

Parameters:

data - message

getReceive

public byte[] getReceive()

Returns:

the polled message from the queue

addSend

public void addSend(byte[] data)

add a message to the queue of sent messages

Parameters:

data -

getSend

public byte[] getSend()

Returns:

the message polled from the queue of messages to send

getReceiveQueue

public java.util.Queue<byte[]> getReceiveQueue()

Returns:

the Queue of received messages

setReceiveQueue

public void setReceiveQueue(java.util.Queue<byte[]> receiveQueue)

Parameters:

receiveQueue - the receiveQueue to set

getSendQueue

public java.util.Queue<byte[]> getSendQueue()

Returns:

the sendQueue

setSendQueue

public void setSendQueue(java.util.Queue<byte[]> sendQueue)

Parameters:

sendQueue - the sendQueue to set