public class ServiceInputConnectionProxy extends Object implements IInputConnection
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.
|
IComponentIdentifier |
getInitiator()
Get the initiator id.
|
Map<String,Object> |
getNonFunctionalProperties()
Get the non-functional properties of the connection.
|
IComponentIdentifier |
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(IComponentIdentifier initiator)
Set the initiator.
|
void |
setNonFunctionalProperties(Map<String,Object> nonfunc)
Set the non-functional properties of the connection.
|
void |
setOutputConnection(IOutputConnection ocon) |
void |
setParticipant(IComponentIdentifier participant)
Set the participant.
|
ISubscriptionIntermediateFuture<Long> |
writeToOutputStream(OutputStream os,
IExternalAccess component)
Read all data from output stream to the connection.
|
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 IComponentIdentifier getInitiator()
getInitiator
in interface IConnection
public void setInitiator(IComponentIdentifier initiator)
initiator
- The initiator to set.public IComponentIdentifier getParticipant()
getParticipant
in interface IConnection
public void setParticipant(IComponentIdentifier participant)
participant
- The participant to set.public Map<String,Object> getNonFunctionalProperties()
getNonFunctionalProperties
in interface IConnection
public void setNonFunctionalProperties(Map<String,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<Long> writeToOutputStream(OutputStream os, IExternalAccess component)
writeToOutputStream
in interface IInputConnection
is
- The input stream.component
- The component.Copyright © 2012. All Rights Reserved.