jadex.bridge.service.types.remote

Class ServiceOutputConnection

java.lang.Object

jadex.bridge.service.types.remote.ServiceOutputConnection

All Implemented Interfaces:

IConnection, IOutputConnection

public class ServiceOutputConnection
extends java.lang.Object
implements IOutputConnection

A service output connection can be used to write data to a remote input connection. For this purpose getInputConnection() has to be called and transferred to the remote side.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<byte[]>	buffer The buffer.
protected boolean	closed The closed flag.
protected IOutputConnection	con The remote output connection.
protected boolean	flushed Flushed flag.
protected jadex.commons.future.Future<java.lang.Integer>	readyfuture The ready future.
protected jadex.commons.ICommand	transfercommand The transfer future.

Constructor Summary

Constructors

Constructor and Description
ServiceOutputConnection() Create a new connection.

Method Summary

Modifier and Type	Method and Description
void	close() Close the connection.
void	flush() Flush the data.
int	getConnectionId() Get the connection id.
ITransportComponentIdentifier	getInitiator() Get the initiator.
IInputConnection	getInputConnection()
java.util.Map<java.lang.String,java.lang.Object>	getNonFunctionalProperties() Get the non-functional properties of the connection.
ITransportComponentIdentifier	getParticipant() Get the participant.
protected void	setOutputConnection(IOutputConnection ocon) Set the real output connection to the other side.
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, IExternalAccess component) Write all data from input stream to the connection.

Methods inherited from class java.lang.Object

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

Field Detail

con

protected IOutputConnection con

The remote output connection.

closed

protected boolean closed

The closed flag.

flushed

protected boolean flushed

Flushed flag.

buffer

protected java.util.List<byte[]> buffer

The buffer.

readyfuture

protected jadex.commons.future.Future<java.lang.Integer> readyfuture

The ready future.

transfercommand

protected jadex.commons.ICommand transfercommand

The transfer future.

Constructor Detail

ServiceOutputConnection

public ServiceOutputConnection()

Create a new connection.

Method Detail

write

public jadex.commons.future.IFuture<java.lang.Void> write(byte[] data)

Write the content to the stream.

Specified by:

write in interface IOutputConnection

Parameters:

data - The data.

flush

public void flush()

Flush the data.

Specified by:

flush in interface IOutputConnection

waitForReady

public jadex.commons.future.IFuture<java.lang.Integer> waitForReady()

Wait until the connection is ready for the next write.

Specified by:

waitForReady in interface IOutputConnection

Returns:

Calls future when next data can be written.

close

public void close()

Close the connection.

Specified by:

close in interface IConnection

getConnectionId

public int getConnectionId()

Description copied from interface: IConnection

Get the connection id.

Specified by:

getConnectionId in interface IConnection

Returns:

The connection id.

getInitiator

public ITransportComponentIdentifier getInitiator()

Description copied from interface: IConnection

Get the initiator.

Specified by:

getInitiator in interface IConnection

Returns:

The initiator.

getParticipant

public ITransportComponentIdentifier getParticipant()

Description copied from interface: IConnection

Get the participant.

Specified by:

getParticipant in interface IConnection

Returns:

The participant.

getNonFunctionalProperties

public java.util.Map<java.lang.String,java.lang.Object> getNonFunctionalProperties()

Get the non-functional properties of the connection.

Specified by:

getNonFunctionalProperties in interface IConnection

getInputConnection

public IInputConnection getInputConnection()

setOutputConnection

protected void setOutputConnection(IOutputConnection ocon)

Set the real output connection to the other side.

writeFromInputStream

public jadex.commons.future.ISubscriptionIntermediateFuture<java.lang.Long> writeFromInputStream(java.io.InputStream is,
                                                                                                 IExternalAccess component)

Write all data from input stream to the connection. The result is an intermediate future that reports back the size that was written. It can also be used to terminate sending.

Specified by:

writeFromInputStream in interface IOutputConnection

Parameters:

is - The input stream.

agen -