public class OutputConnection extends AbstractConnection implements jadex.bridge.IOutputConnection
ch, closed, closing, id, ini, inited, initiator, input, participant
Constructor and Description |
---|
OutputConnection(jadex.bridge.ITransportComponentIdentifier sender,
jadex.bridge.ITransportComponentIdentifier receiver,
int id,
boolean initiator,
IOutputConnectionHandler ch)
Create a new connection.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the connection.
|
void |
flush()
Flush the data.
|
jadex.commons.future.IFuture<java.lang.Integer> |
waitForReady()
Wait until the connection is ready for the next write.
|
jadex.commons.future.IFuture<java.lang.Void> |
write(byte[] data)
Write the content to the stream.
|
jadex.commons.future.ISubscriptionIntermediateFuture<java.lang.Long> |
writeFromInputStream(java.io.InputStream is,
jadex.bridge.IExternalAccess component)
Do write all data from the input stream.
|
getConnectionHandler, getConnectionId, getInitiator, getNonFunctionalProperties, getParticipant, isClosed, isClosing, isInited, isInitiatorSide, isInputConnection, setClosed, setClosing, setInited
public OutputConnection(jadex.bridge.ITransportComponentIdentifier sender, jadex.bridge.ITransportComponentIdentifier receiver, int id, boolean initiator, IOutputConnectionHandler ch)
public jadex.commons.future.IFuture<java.lang.Void> write(byte[] data)
write
in interface jadex.bridge.IOutputConnection
data
- The data.public void flush()
flush
in interface jadex.bridge.IOutputConnection
public jadex.commons.future.IFuture<java.lang.Integer> waitForReady()
waitForReady
in interface jadex.bridge.IOutputConnection
public void close()
close
in interface jadex.bridge.IConnection
close
in class AbstractConnection
public jadex.commons.future.ISubscriptionIntermediateFuture<java.lang.Long> writeFromInputStream(java.io.InputStream is, jadex.bridge.IExternalAccess component)
writeFromInputStream
in interface jadex.bridge.IOutputConnection