com.ionetrics.lib.annotatorcomm
Class ResponseMessageQueue

java.lang.Object
  extended by com.ionetrics.lib.annotatorcomm.ResponseMessageQueue
All Implemented Interfaces:
java.io.Closeable

public class ResponseMessageQueue
extends java.lang.Object
implements java.io.Closeable

The ResponseMessageQueue queues messages for retrieval.


Constructor Summary
ResponseMessageQueue()
           
 
Method Summary
 void close()
          Close the ResponseMessageQueue.
 ResponseMessage get()
          Get a message from the queue.
 void put(ResponseMessage msg)
          Put a message into the queue.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ResponseMessageQueue

public ResponseMessageQueue()
Method Detail

close

public void close()
           throws java.io.IOException
Close the ResponseMessageQueue.

Specified by:
close in interface java.io.Closeable
Throws:
java.io.IOException - failure to close

get

public ResponseMessage get()
                    throws java.io.IOException
Get a message from the queue. If there are no message available, wait until one arrives. If a message does not arrive within the timeout period, an IOException is thrown.

Returns:
response message
Throws:
java.io.IOException - failure to get a message (closed or timed out)

put

public void put(ResponseMessage msg)
Put a message into the queue.

Parameters:
msg - response message


Copyright © 2006 Ionetrics Corp. All Rights Reserved.