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 Object
implements IInputConnection

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
ISubscriptionIntermediateFuture<byte[]>	aread() Asynchronous read.
int	available() Get the number of available bytes.
void	close() Close the stream.
int	getConnectionId() Get the connection id.
IComponentIdentifier	getInitiator() Get the initiator.
Map<String,Object>	getNonFunctionalProperties() Get the non-functional properties of the connection.
IOutputConnection	getOutputConnection() Get the corresponding output connection.
IComponentIdentifier	getParticipant() Get the participant.
int	read() Non-blocking read.
int	read(byte[] buffer) Non-blocking read.
ISubscriptionIntermediateFuture<Long>	writeToOutputStream(OutputStream os, IExternalAccess component) Read all data from output stream to the connection.

Methods inherited from class java.lang.Object

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

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 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 IComponentIdentifier getInitiator()

Get the initiator.

Specified by:

getInitiator in interface IConnection

Returns:

The initiator.

getParticipant

public IComponentIdentifier getParticipant()

Get the participant.

Specified by:

getParticipant in interface IConnection

Returns:

The participant.

getNonFunctionalProperties

public Map<String,Object> getNonFunctionalProperties()

Get the non-functional properties of the connection.

Specified by:

getNonFunctionalProperties in interface IConnection

getOutputConnection

public IOutputConnection getOutputConnection()

Get the corresponding output connection.

writeToOutputStream

public ISubscriptionIntermediateFuture<Long> writeToOutputStream(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.