jadex.bridge.service.types.remote

Class ServiceInputConnection

java.lang.Object

jadex.bridge.service.types.remote.ServiceInputConnection

All Implemented Interfaces:

IConnection, IInputConnection

public class ServiceInputConnection
extends java.lang.Object
implements IInputConnection

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	closed The closed flag.
protected IInputConnection	con The remote output connection.
protected jadex.commons.future.SubscriptionIntermediateFuture<byte[]>	future The buffer.
protected jadex.commons.ICommand	transfercommand The transfer future.
protected jadex.commons.future.ITerminableIntermediateFuture<java.lang.Long>	transferfuture The transfer future.

Constructor Summary

Constructors

Constructor and Description
ServiceInputConnection() Create a new service input connection.

Method Summary

Modifier and Type	Method and Description
jadex.commons.future.ISubscriptionIntermediateFuture<byte[]>	aread() Asynchronous read.
int	available() Get the number of available bytes.
void	close() Close the stream.
int	getConnectionId() Get the connection id.
ITransportComponentIdentifier	getInitiator() Get the initiator.
java.util.Map<java.lang.String,java.lang.Object>	getNonFunctionalProperties() Get the non-functional properties of the connection.
IOutputConnection	getOutputConnection() Get the corresponding output connection.
ITransportComponentIdentifier	getParticipant() Get the participant.
int	read() Non-blocking read.
int	read(byte[] buffer) Non-blocking read.
protected void	setInputConnection(IInputConnection con) Set the input connection.
jadex.commons.future.ISubscriptionIntermediateFuture<java.lang.Long>	writeToOutputStream(java.io.OutputStream os, IExternalAccess component) Read all data from output 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 IInputConnection con

The remote output connection.

closed

protected boolean closed

The closed flag.

future

protected jadex.commons.future.SubscriptionIntermediateFuture<byte[]> future

The buffer.

transferfuture

protected jadex.commons.future.ITerminableIntermediateFuture<java.lang.Long> transferfuture

The transfer future.

transfercommand

protected jadex.commons.ICommand transfercommand

The transfer future.

Constructor Detail

ServiceInputConnection

public ServiceInputConnection()

Create a new service input connection.

Method Detail

read

public int read()

Non-blocking read. Tries to read the next byte.

Specified by:

read in interface IInputConnection

Returns:

The next byte or -1 if none is currently available.

read

public int read(byte[] buffer)

Non-blocking read. Tries to fill the buffer from the stream.

Specified by:

read in interface IInputConnection

Parameters:

buffer - The buffer to read in.

Returns:

The number of bytes that could be read into the buffer.

aread

public jadex.commons.future.ISubscriptionIntermediateFuture<byte[]> aread()

Asynchronous read.

Specified by:

aread in interface IInputConnection

Returns:

Bytes one by one till end of stream or closed.

available

public int available()

Get the number of available bytes.

Specified by:

available in interface IInputConnection

Returns:

The number of available bytes.

getConnectionId

public int getConnectionId()

Get the connection id.

Specified by:

getConnectionId in interface IConnection

Returns:

The connection id.

close

public void close()

Close the stream.

Specified by:

close in interface IConnection

getInitiator

public ITransportComponentIdentifier getInitiator()

Get the initiator.

Specified by:

getInitiator in interface IConnection

Returns:

The initiator.

getParticipant

public ITransportComponentIdentifier getParticipant()

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

setInputConnection

protected void setInputConnection(IInputConnection con)

Set the input connection.

getOutputConnection

public IOutputConnection getOutputConnection()

Get the corresponding output connection.

writeToOutputStream

public jadex.commons.future.ISubscriptionIntermediateFuture<java.lang.Long> writeToOutputStream(java.io.OutputStream os,
                                                                                                IExternalAccess component)

Read all data from output stream to the connection. The result is an intermediate future that reports back the size that was read. It can also be used to terminate reading.

Specified by:

writeToOutputStream in interface IInputConnection

Parameters:

is - The input stream.

component - The component.