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

Constructors

Constructor and Description
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

Modifier and Type	Method and Description
void	close() Closes the sender.
boolean	connect(java.lang.String user, java.lang.String password)
<T> T	createProxy(java.lang.Class<T> api, java.lang.String address)
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()
void	setTimeout(long timeout) The default query timeout.
java.lang.String	toString()

Methods inherited from class com.caucho.bam.actor.AbstractActorSender

getQueryManager, getTimeout, isClosed, message, message, nextQueryId, query, query, query, query, query, query, queryFuture

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, message, nextQueryId, query, query, query, 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

setTimeout

public void setTimeout(long timeout)

Description copied from class: AbstractActorSender

The default query timeout.

Overrides:

setTimeout in class AbstractActorSender

createProxy

public <T> T createProxy(java.lang.Class<T> api,
                         java.lang.String address)

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