net.sergeych.farcall

Class Interconnection.QueueConnector

java.lang.Object

net.sergeych.farcall.Interconnection.QueueConnector

All Implemented Interfaces:

Connector

Enclosing class:

Interconnection

public class Interconnection.QueueConnector
extends java.lang.Object
implements Connector

Constructor Summary

Constructors

Constructor and Description
QueueConnector(java.util.concurrent.BlockingQueue<java.lang.Object> input, java.util.concurrent.BlockingQueue<java.lang.Object> output)

Method Summary

Modifier and Type	Method and Description
void	close() Called by protocol when it is closing, and will not send and receive data anymore.
boolean	isClosed()
Interconnection.QueueConnector	pause(long millis)
java.util.Map<java.lang.String,java.lang.Object>	receive() Block until the connection is closed or a valid package is received.
void	send(java.util.Map<java.lang.String,java.lang.Object> data) Pack and send farcall data
Interconnection.QueueConnector	trace(boolean on)

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueConnector

public QueueConnector(java.util.concurrent.BlockingQueue<java.lang.Object> input,
                      java.util.concurrent.BlockingQueue<java.lang.Object> output)

Method Detail

send

public void send(java.util.Map<java.lang.String,java.lang.Object> data)
          throws java.io.IOException

Description copied from interface: Connector

Pack and send farcall data

Specified by:

send in interface Connector

Throws:

java.io.IOException

receive

public java.util.Map<java.lang.String,java.lang.Object> receive()
                                                         throws java.io.IOException

Description copied from interface: Connector

Block until the connection is closed or a valid package is received. Connector unpacks the package and returns it.

Specified by:

receive in interface Connector

Returns:

unpacked data or null to signal eof state.

Throws:

java.io.IOException

close

public void close()

Description copied from interface: Connector

Called by protocol when it is closing, and will not send and receive data anymore. Connector can expilcitly close streams and free resources at this point.

Specified by:

close in interface Connector

isClosed

public boolean isClosed()

trace

public Interconnection.QueueConnector trace(boolean on)

pause

public Interconnection.QueueConnector pause(long millis)