public class ServiceInputConnectionProxy extends java.lang.Object implements IInputConnection
Modifier and Type | Field and Description |
---|---|
protected ServiceOutputConnection |
con
The original connection (not transferred).
|
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 |
---|
ServiceInputConnectionProxy() |
ServiceInputConnectionProxy(ServiceOutputConnection con) |
Modifier and Type | Method and Description |
---|---|
ISubscriptionIntermediateFuture<byte[]> |
aread()
Asynchronous read.
|
int |
available()
Get the number of available bytes.
|
void |
close()
Close the connection.
|
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.
|
int |
read()
Non-blocking read.
|
int |
read(byte[] buffer)
Non-blocking read.
|
void |
setConnectionId(int conid)
Set the connectionid.
|
void |
setInitiator(ITransportComponentIdentifier initiator)
Set the initiator.
|
void |
setNonFunctionalProperties(java.util.Map<java.lang.String,java.lang.Object> nonfunc)
Set the non-functional properties of the connection.
|
void |
setOutputConnection(IOutputConnection ocon) |
void |
setParticipant(ITransportComponentIdentifier participant)
Set the participant.
|
ISubscriptionIntermediateFuture<java.lang.Long> |
writeToOutputStream(java.io.OutputStream os,
IExternalAccess component)
Read all data from output stream to the connection.
|
protected ServiceOutputConnection con
protected int conid
protected ITransportComponentIdentifier initiator
protected ITransportComponentIdentifier participant
protected java.util.Map<java.lang.String,java.lang.Object> nonfunc
public ServiceInputConnectionProxy()
public ServiceInputConnectionProxy(ServiceOutputConnection con)
public void setOutputConnection(IOutputConnection ocon)
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 int read(byte[] buffer)
IInputConnection
read
in interface IInputConnection
buffer
- The buffer to read in.public int read()
IInputConnection
read
in interface IInputConnection
public int available()
available
in interface IInputConnection
public void close()
IConnection
close
in interface IConnection
public ISubscriptionIntermediateFuture<byte[]> aread()
IInputConnection
aread
in interface IInputConnection
public ISubscriptionIntermediateFuture<java.lang.Long> writeToOutputStream(java.io.OutputStream os, IExternalAccess component)
writeToOutputStream
in interface IInputConnection
is
- The input stream.component
- The component.