com.caucho.hmtp
Class HmtpLinkWorker

java.lang.Object
  extended by com.caucho.hmtp.HmtpLinkWorker
All Implemented Interfaces:
java.lang.Runnable
Direct Known Subclasses:
ResinLink

public class HmtpLinkWorker
extends java.lang.Object
implements java.lang.Runnable

HMTP client protocol


Field Summary
protected  java.io.InputStream _is
           
protected  java.io.OutputStream _os
           
 
Constructor Summary
HmtpLinkWorker(ActorHolder actor, java.io.InputStream is, java.io.OutputStream os)
           
 
Method Summary
 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)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_is

protected java.io.InputStream _is

_os

protected java.io.OutputStream _os
Constructor Detail

HmtpLinkWorker

public HmtpLinkWorker(ActorHolder actor,
                      java.io.InputStream is,
                      java.io.OutputStream os)
               throws java.io.IOException
Throws:
java.io.IOException
Method Detail

getAddress

public java.lang.String getAddress()

setAddress

public void setAddress(java.lang.String address)

getLinkStream

public MessageStream getLinkStream()

getActorStream

public MessageStream getActorStream()
Returns the current stream to the actor, throwing an exception if it's unavailable


isClosed

public boolean isClosed()

run

public void run()
Receive messages from the client

Specified by:
run in interface java.lang.Runnable

close

public void close()