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 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.

Constructor Summary

Constructors

Constructor and Description
ServiceOutputConnection() Create a new connection.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close the connection.
void	flush() Flush the data.
int	getConnectionId() Get the connection id.
IComponentIdentifier	getInitiator() Get the initiator.
IInputConnection	getInputConnection()
Map<String,Object>	getNonFunctionalProperties() Get the non-functional properties of the connection.
IComponentIdentifier	getParticipant() Get the participant.
IFuture<Integer>	waitForReady() Wait until the connection is ready for the next write.
IFuture<Void>	write(byte[] data) Write the content to the stream.
ISubscriptionIntermediateFuture<Long>	writeFromInputStream(InputStream is, IExternalAccess component) Write all data from input stream to the connection.

Methods inherited from class java.lang.Object

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

Constructor Detail

ServiceOutputConnection

public ServiceOutputConnection()

Create a new connection.

Method Detail

write

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

Description copied from interface: IConnection

Get the initiator.

Specified by:

getInitiator in interface IConnection

Returns:

The initiator.

getParticipant

public IComponentIdentifier getParticipant()

Description copied from interface: IConnection

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

getInputConnection

public IInputConnection getInputConnection()

writeFromInputStream

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