public class Interconnection.QueueConnector extends java.lang.Object implements Connector
| Constructor and Description |
|---|
QueueConnector(java.util.concurrent.BlockingQueue<java.lang.Object> input,
java.util.concurrent.BlockingQueue<java.lang.Object> output) |
| 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) |
public QueueConnector(java.util.concurrent.BlockingQueue<java.lang.Object> input,
java.util.concurrent.BlockingQueue<java.lang.Object> output)
public void send(java.util.Map<java.lang.String,java.lang.Object> data)
throws java.io.IOException
Connectorpublic java.util.Map<java.lang.String,java.lang.Object> receive()
throws java.io.IOException
Connectorpublic void close()
Connectorpublic boolean isClosed()
public Interconnection.QueueConnector trace(boolean on)
public Interconnection.QueueConnector pause(long millis)