com.caucho.jms.cluster
Class HmuxReceiver

java.lang.Object
  com.caucho.bam.AbstractBamService
      com.caucho.bam.SimpleBamService
          com.caucho.jms.cluster.HmuxReceiver

All Implemented Interfaces:

BamService, BamStream

public class HmuxReceiver
extends SimpleBamService

Receives hmux requests

Field Summary

static int	HMUX_ACK
static int	HMUX_BODY
static int	HMUX_DATA_END
static int	HMUX_HAS_MESSAGE
static int	HMUX_MESSAGE
static int	HMUX_MSG_ID
static int	HMUX_POLL
static int	HMUX_PROPERTIES
static int	HMUX_QUEUE
static int	HMUX_RECEIVE
static int	HMUX_REDELIVERED
static int	HMUX_ROLLBACK
static int	HMUX_SEND
static int	HMUX_SUBSCRIBER

Method Summary

static HmuxReceiver	create()
java.lang.String	getJid() Returns the jid
ServerDestination	getQueue(java.lang.String name)
void	message(java.lang.String to, java.lang.String from, java.io.Serializable query) Handles update queries
boolean	querySet(long id, java.lang.String to, java.lang.String from, java.io.Serializable query) Handles update queries
void	removeQueue(java.lang.String name)
void	setQueue(java.lang.String name, ServerDestination queue)

Methods inherited from class com.caucho.bam.SimpleBamService

getAgentStream, getBamSkeleton, getBrokerStream, messageError, presence, presenceError, presenceProbe, presenceSubscribe, presenceSubscribed, presenceUnavailable, presenceUnsubscribe, presenceUnsubscribed, queryError, queryGet, queryResult, setBrokerStream

Methods inherited from class com.caucho.bam.AbstractBamService

getAgentFilter, getBrokerFilter, logData, logValue, onAgentStart, onAgentStop, setJid, startAgent, stopAgent, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

HMUX_ACK

public static final int HMUX_ACK

See Also:

Constant Field Values

HMUX_QUEUE

public static final int HMUX_QUEUE

See Also:

Constant Field Values

HMUX_MESSAGE

public static final int HMUX_MESSAGE

See Also:

Constant Field Values

HMUX_MSG_ID

public static final int HMUX_MSG_ID

See Also:

Constant Field Values

HMUX_RECEIVE

public static final int HMUX_RECEIVE

See Also:

Constant Field Values

HMUX_SEND

public static final int HMUX_SEND

See Also:

Constant Field Values

HMUX_SUBSCRIBER

public static final int HMUX_SUBSCRIBER

See Also:

Constant Field Values

HMUX_POLL

public static final int HMUX_POLL

See Also:

Constant Field Values

HMUX_HAS_MESSAGE

public static final int HMUX_HAS_MESSAGE

See Also:

Constant Field Values

HMUX_ROLLBACK

public static final int HMUX_ROLLBACK

See Also:

Constant Field Values

HMUX_REDELIVERED

public static final int HMUX_REDELIVERED

See Also:

Constant Field Values

HMUX_PROPERTIES

public static final int HMUX_PROPERTIES

See Also:

Constant Field Values

HMUX_BODY

public static final int HMUX_BODY

See Also:

Constant Field Values

HMUX_DATA_END

public static final int HMUX_DATA_END

See Also:

Constant Field Values

Method Detail

create

public static HmuxReceiver create()

getJid

public java.lang.String getJid()

Description copied from class: AbstractBamService

Returns the jid

Specified by:

getJid in interface BamService

Specified by:

getJid in interface BamStream

Overrides:

getJid in class AbstractBamService

getQueue

public ServerDestination getQueue(java.lang.String name)

setQueue

public void setQueue(java.lang.String name,
                     ServerDestination queue)

removeQueue

public void removeQueue(java.lang.String name)

message

public void message(java.lang.String to,
                    java.lang.String from,
                    java.io.Serializable query)

Handles update queries

Specified by:

message in interface BamStream

Overrides:

message in class SimpleBamService

Parameters:

to - the target JID

from - the source JID

query - the message payload

querySet

public boolean querySet(long id,
                        java.lang.String to,
                        java.lang.String from,
                        java.io.Serializable query)

Handles update queries

Specified by:

querySet in interface BamStream

Overrides:

querySet in class SimpleBamService

Parameters:

id - the query identifier used to match requests with responses

to - the target JID

from - the source JID, used as the target for the response

query - the query payload

Returns:

true if this handler understand the query, false otherwise