org.qbroker.cluster

Class PacketProxy

java.lang.Object

org.qbroker.cluster.PacketProxy

All Implemented Interfaces:

java.lang.Runnable

public class PacketProxy
extends java.lang.Object
implements java.lang.Runnable

PacketProxy is a proxy forwarding UDP packets to existing destinations. As a utility, it can ack like an observer for a cluster.

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEBUG_ALL
static int	DEBUG_CHECK
static int	DEBUG_CLOSE
static int	DEBUG_EXAM
static int	DEBUG_HBEAT
static int	DEBUG_INIT
static int	DEBUG_NONE
static int	DEBUG_RELAY

Constructor Summary

Constructors

Constructor and Description
PacketProxy(java.util.Map props)

Method Summary

Modifier and Type	Method and Description
void	close()
static void	main(java.lang.String[] args)
void	run()
void	start() It starts the cluster node and supervises its state.

Methods inherited from class java.lang.Object

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

Field Detail

DEBUG_NONE

public static final int DEBUG_NONE

See Also:

Constant Field Values

DEBUG_INIT

public static final int DEBUG_INIT

See Also:

Constant Field Values

DEBUG_EXAM

public static final int DEBUG_EXAM

See Also:

Constant Field Values

DEBUG_CHECK

public static final int DEBUG_CHECK

See Also:

Constant Field Values

DEBUG_RELAY

public static final int DEBUG_RELAY

See Also:

Constant Field Values

DEBUG_CLOSE

public static final int DEBUG_CLOSE

See Also:

Constant Field Values

DEBUG_HBEAT

public static final int DEBUG_HBEAT

See Also:

Constant Field Values

DEBUG_ALL

public static final int DEBUG_ALL

See Also:

Constant Field Values

Constructor Detail

PacketProxy

public PacketProxy(java.util.Map props)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

close

public void close()

start

public void start()

It starts the cluster node and supervises its state. With the communication XQueue defined, the cluster node will escalate or relay events to/from external caller via the XQueue. The cluster node will keep running until its shutdown.

main

public static void main(java.lang.String[] args)