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

Constructor Summary

Constructors

Constructor and Description
ServiceOutputConnectionProxy()
ServiceOutputConnectionProxy(ServiceInputConnection con)

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

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

Get the initiator id.

Specified by:

getInitiator in interface IConnection

Returns:

The initiator id.

setInitiator

public void setInitiator(IComponentIdentifier initiator)

Set the initiator.

Parameters:

initiator - The initiator to set.

getParticipant

public IComponentIdentifier getParticipant()

Get the participant id.

Specified by:

getParticipant in interface IConnection

Returns:

The participant id.

setParticipant

public void setParticipant(IComponentIdentifier participant)

Set the participant.

Parameters:

participant - The participant to set.

getNonFunctionalProperties

public Map<String,Object> getNonFunctionalProperties()

Get the non-functional properties of the connection.

Specified by:

getNonFunctionalProperties in interface IConnection

Returns:

The properties.

setNonFunctionalProperties

public void setNonFunctionalProperties(Map<String,Object> nonfunc)

Set the non-functional properties of the connection.

Parameters:

nonfunc - The properties.

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

writeFromInputStream

public ISubscriptionIntermediateFuture<Long> writeFromInputStream(InputStream is,
                                                         IExternalAccess component)

Do write all data from the input stream.

Specified by:

writeFromInputStream in interface IOutputConnection

Parameters:

is - The input stream.