public class HmtpLinkWorker
extends java.lang.Object
implements java.lang.Runnable
| Modifier and Type | Field and Description |
|---|---|
protected java.io.InputStream |
_is |
protected java.io.OutputStream |
_os |
| Constructor and Description |
|---|
HmtpLinkWorker(ActorHolder actor,
java.io.InputStream is,
java.io.OutputStream os) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
MessageStream |
getActorStream()
Returns the current stream to the actor, throwing an exception if
it's unavailable
|
java.lang.String |
getAddress() |
MessageStream |
getLinkStream() |
boolean |
isClosed() |
void |
run()
Receive messages from the client
|
void |
setAddress(java.lang.String address) |
public HmtpLinkWorker(ActorHolder actor, java.io.InputStream is, java.io.OutputStream os) throws java.io.IOException
java.io.IOExceptionpublic java.lang.String getAddress()
public void setAddress(java.lang.String address)
public MessageStream getLinkStream()
public MessageStream getActorStream()
public boolean isClosed()
public void run()
run in interface java.lang.Runnablepublic void close()