com.caucho.server.cluster
Class HmuxClient

java.lang.Object
  extended by com.caucho.bam.actor.AbstractActorSender
      extended by com.caucho.server.cluster.HmuxClient
All Implemented Interfaces:
ActorSender, RemoteActorSender, QuerySender

public class HmuxClient
extends AbstractActorSender
implements RemoteActorSender


Constructor Summary
HmuxClient(ClientSocketFactory pool)
           
HmuxClient(java.lang.String serverId)
           
HmuxClient(java.lang.String host, int port)
           
HmuxClient(java.lang.String host, int port, java.lang.String userName, java.lang.String password)
           
HmuxClient(java.lang.String serverId, java.lang.String userName, java.lang.String password)
           
 
Method Summary
 void close()
          Closes the sender.
 boolean connect(java.lang.String user, java.lang.String password)
           
 java.lang.String getAddress()
          Returns the Actor's address used for all "from" parameters.
 Broker getBroker()
          The underlying broker.
protected  Mailbox getClientMailbox()
           
 java.lang.String getUrl()
           
 java.lang.String toString()
           
 
Methods inherited from class com.caucho.bam.actor.AbstractActorSender
getQueryManager, getTimeout, isClosed, message, nextQueryId, query, query, query, queryFuture, setTimeout
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface com.caucho.bam.actor.ActorSender
isClosed, message, nextQueryId, query, query, query
 
Methods inherited from interface com.caucho.bam.query.QuerySender
getQueryManager
 

Constructor Detail

HmuxClient

public HmuxClient(ClientSocketFactory pool)

HmuxClient

public HmuxClient(java.lang.String serverId)

HmuxClient

public HmuxClient(java.lang.String serverId,
                  java.lang.String userName,
                  java.lang.String password)
           throws java.io.IOException
Throws:
java.io.IOException

HmuxClient

public HmuxClient(java.lang.String host,
                  int port)

HmuxClient

public HmuxClient(java.lang.String host,
                  int port,
                  java.lang.String userName,
                  java.lang.String password)
           throws java.io.IOException
Throws:
java.io.IOException
Method Detail

getAddress

public java.lang.String getAddress()
Description copied from interface: QuerySender
Returns the Actor's address used for all "from" parameters.

Specified by:
getAddress in interface QuerySender

getBroker

public Broker getBroker()
Description copied from class: AbstractActorSender
The underlying broker.

Specified by:
getBroker in interface ActorSender
Specified by:
getBroker in interface QuerySender
Specified by:
getBroker in class AbstractActorSender

connect

public boolean connect(java.lang.String user,
                       java.lang.String password)
                throws java.io.IOException
Throws:
java.io.IOException

getUrl

public java.lang.String getUrl()
Specified by:
getUrl in interface RemoteActorSender

getClientMailbox

protected Mailbox getClientMailbox()

close

public void close()
Description copied from class: AbstractActorSender
Closes the sender.

Specified by:
close in interface ActorSender
Overrides:
close in class AbstractActorSender

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object