com.caucho.server.cluster
Class HmuxClient

java.lang.Object
  com.caucho.bam.actor.AbstractActorSender
      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