com.caucho.jms.cluster

Class MessageSystem

java.lang.Object

com.caucho.env.service.AbstractResinSubSystem

com.caucho.jms.cluster.MessageSystem

All Implemented Interfaces:

ResinSubSystem

public class MessageSystem
extends AbstractResinSubSystem

Service for handling the cluster heartbeat messages

Field Summary

Fields

Modifier and Type	Field and Description
static int	START_PRIORITY

Fields inherited from interface com.caucho.env.service.ResinSubSystem

START_PRIORITY_CACHE_SERVICE, START_PRIORITY_CLASSLOADER, START_PRIORITY_CLUSTER_SERVICE, START_PRIORITY_DATABASE_SYSTEM, START_PRIORITY_DEFAULT, START_PRIORITY_ENV_SYSTEM, START_PRIORITY_NETWORK_CLUSTER, STOP_PRIORITY_CLASSLOADER

Method Summary

Modifier and Type	Method and Description
static MessageSystem	createAndAddService(CloudServer server)
ClusterQueueActor	getActor()
static MessageSystem	getCurrent()
int	getStartPriority() Returns the start priority of the service, used to determine which services to start first.
void	start() Starts the heartbeat actor with a server start message to the pod
void	stop() Stops the heartbeat actor with a server start message to the pod

Methods inherited from class com.caucho.env.service.AbstractResinSubSystem

destroy, getStopPriority, isActive, preCreate, toString

Methods inherited from class java.lang.Object

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

Field Detail

START_PRIORITY

public static final int START_PRIORITY

See Also:

Constant Field Values

Method Detail

createAndAddService

public static MessageSystem createAndAddService(CloudServer server)

getCurrent

public static MessageSystem getCurrent()

getActor

public ClusterQueueActor getActor()

getStartPriority

public int getStartPriority()

Description copied from interface: ResinSubSystem

Returns the start priority of the service, used to determine which services to start first.

Specified by:

getStartPriority in interface ResinSubSystem

Overrides:

getStartPriority in class AbstractResinSubSystem

start

public void start()

Starts the heartbeat actor with a server start message to the pod

Specified by:

start in interface ResinSubSystem

Overrides:

start in class AbstractResinSubSystem

stop

public void stop()

Stops the heartbeat actor with a server start message to the pod

Specified by:

stop in interface ResinSubSystem

Overrides:

stop in class AbstractResinSubSystem