jadex.bridge.service.types.remote

Class ServiceOutputConnectionProxy

java.lang.Object

jadex.bridge.service.types.remote.ServiceOutputConnectionProxy

All Implemented Interfaces:

IConnection, IOutputConnection

public class ServiceOutputConnectionProxy
extends java.lang.Object
implements IOutputConnection

Field Summary

Fields

Modifier and Type	Field and Description
protected ServiceInputConnection	con The original connection.
protected int	conid The connection id.
protected ITransportComponentIdentifier	initiator The initiator id.
protected java.util.Map<java.lang.String,java.lang.Object>	nonfunc The non-functional properties.
protected ITransportComponentIdentifier	participant The participant id.

Constructor Summary

Constructors

Constructor and Description
ServiceOutputConnectionProxy()
ServiceOutputConnectionProxy(ServiceInputConnection con)

Method Summary

Modifier and Type	Method and Description
void	close() Close the connection.
void	flush() Flush the data.
int	getConnectionId() Get the connectionid.
ITransportComponentIdentifier	getInitiator() Get the initiator id.
java.util.Map<java.lang.String,java.lang.Object>	getNonFunctionalProperties() Get the non-functional properties of the connection.
ITransportComponentIdentifier	getParticipant() Get the participant id.
void	setConnectionId(int conid) Set the connectionid.
void	setInitiator(ITransportComponentIdentifier initiator) Set the initiator.
void	setInputConnection(IInputConnection icon)
void	setNonFunctionalProperties(java.util.Map<java.lang.String,java.lang.Object> nonfunc) Set the non-functional properties of the connection.
void	setParticipant(ITransportComponentIdentifier participant) Set the participant.
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) Do write all data from the input stream.

Methods inherited from class java.lang.Object

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

Field Detail

con

protected ServiceInputConnection con

The original connection.

conid

protected int conid

The connection id.

initiator

protected ITransportComponentIdentifier initiator

The initiator id.

participant

protected ITransportComponentIdentifier participant

The participant id.

nonfunc

protected java.util.Map<java.lang.String,java.lang.Object> nonfunc

The non-functional properties.

Constructor Detail

ServiceOutputConnectionProxy

public ServiceOutputConnectionProxy()

ServiceOutputConnectionProxy

public ServiceOutputConnectionProxy(ServiceInputConnection con)

Method Detail

setInputConnection

public void setInputConnection(IInputConnection icon)

getConnectionId

public int getConnectionId()

Get the connectionid.

Specified by:

getConnectionId in interface IConnection

Returns:

The connectionid.

setConnectionId

public void setConnectionId(int conid)

Set the connectionid.

Parameters:

connectionid - The connectionid to set.

getInitiator

public ITransportComponentIdentifier getInitiator()

Get the initiator id.

Specified by:

getInitiator in interface IConnection

Returns:

The initiator id.

setInitiator

public void setInitiator(ITransportComponentIdentifier initiator)

Set the initiator.

Parameters:

initiator - The initiator to set.

getParticipant

public ITransportComponentIdentifier getParticipant()

Get the participant id.

Specified by:

getParticipant in interface IConnection

Returns:

The participant id.

setParticipant

public void setParticipant(ITransportComponentIdentifier participant)

Set the participant.

Parameters:

participant - The participant to set.

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

Returns:

The properties.

setNonFunctionalProperties

public void setNonFunctionalProperties(java.util.Map<java.lang.String,java.lang.Object> nonfunc)

Set the non-functional properties of the connection.

Parameters:

nonfunc - The properties.

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

writeFromInputStream

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

Do write all data from the input stream.

Specified by:

writeFromInputStream in interface IOutputConnection

Parameters:

is - The input stream.