public class ServiceOutputConnectionProxy extends java.lang.Object implements IOutputConnection
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 and Description |
---|
ServiceOutputConnectionProxy() |
ServiceOutputConnectionProxy(ServiceInputConnection con) |
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.
|
IFuture<java.lang.Integer> |
waitForReady()
Wait until the connection is ready for the next write.
|
IFuture<java.lang.Void> |
write(byte[] data)
Write the content to the stream.
|
ISubscriptionIntermediateFuture<java.lang.Long> |
writeFromInputStream(java.io.InputStream is,
IExternalAccess component)
Do write all data from the input stream.
|
protected ServiceInputConnection con
protected int conid
protected ITransportComponentIdentifier initiator
protected ITransportComponentIdentifier participant
protected java.util.Map<java.lang.String,java.lang.Object> nonfunc
public ServiceOutputConnectionProxy()
public ServiceOutputConnectionProxy(ServiceInputConnection con)
public void setInputConnection(IInputConnection icon)
public int getConnectionId()
getConnectionId
in interface IConnection
public void setConnectionId(int conid)
connectionid
- The connectionid to set.public ITransportComponentIdentifier getInitiator()
getInitiator
in interface IConnection
public void setInitiator(ITransportComponentIdentifier initiator)
initiator
- The initiator to set.public ITransportComponentIdentifier getParticipant()
getParticipant
in interface IConnection
public void setParticipant(ITransportComponentIdentifier participant)
participant
- The participant to set.public java.util.Map<java.lang.String,java.lang.Object> getNonFunctionalProperties()
getNonFunctionalProperties
in interface IConnection
public void setNonFunctionalProperties(java.util.Map<java.lang.String,java.lang.Object> nonfunc)
nonfunc
- The properties.public IFuture<java.lang.Void> write(byte[] data)
write
in interface IOutputConnection
data
- The data.public void flush()
flush
in interface IOutputConnection
public IFuture<java.lang.Integer> waitForReady()
waitForReady
in interface IOutputConnection
public void close()
close
in interface IConnection
public ISubscriptionIntermediateFuture<java.lang.Long> writeFromInputStream(java.io.InputStream is, IExternalAccess component)
writeFromInputStream
in interface IOutputConnection
is
- The input stream.