org.qbroker.node

Class NodeUtils

java.lang.Object

org.qbroker.node.NodeUtils

public class NodeUtils
extends java.lang.Object

NodeUtils contains a bunch of constants and static methods on brokers for common uses

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
static int	FAILURE_OUT
static int	NOHIT_OUT
static int	OF_HOLDON
static int	OF_KEEPNEW
static int	OF_KEEPOLD
static int	RESULT_OUT

Constructor Summary

Constructors

Constructor and Description
NodeUtils() default constructor for NodeUtils

Method Summary

Modifier and Type	Method and Description
static int	getOutstandingSize(XQueue xq, int begin, int len) returns number of outstanding messages for the given xqueue
static java.util.Map<java.lang.String,java.lang.Object>	getReport(java.lang.String name) returns the report map of the name from the default container
static AssetList	initFixedOutLinks(long tm, int outCapacity, int size, int[] overlap, java.lang.String name, java.util.List list) It initializes all fixed outLinks stored in list and returns an instance of AssetList with metaData on each of valid outLinks.
static AssetList	initOutLinks(long tm, int outCapacity, int size, int overflow, java.lang.String name, java.util.List list) It initializes all outLinks stored in list and returns an instance of AssetList with metaData on each of outLinks.
static int	passthru(long waitTime, javax.jms.Message msg, XQueue in, XQueue out, long[] outInfo, int option) puts a msg to out XQ with overflowOption implemented and returns a non-negative number upon success or -1 otherwise
static void	stopRunning(XQueue xq)

Methods inherited from class java.lang.Object

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

Field Detail

OF_HOLDON

public static final int OF_HOLDON

See Also:

Constant Field Values

OF_KEEPNEW

public static final int OF_KEEPNEW

See Also:

Constant Field Values

OF_KEEPOLD

public static final int OF_KEEPOLD

See Also:

Constant Field Values

RESULT_OUT

public static final int RESULT_OUT

See Also:

Constant Field Values

FAILURE_OUT

public static final int FAILURE_OUT

See Also:

Constant Field Values

NOHIT_OUT

public static final int NOHIT_OUT

See Also:

Constant Field Values

Constructor Detail

NodeUtils

public NodeUtils()

default constructor for NodeUtils

Method Detail

initFixedOutLinks

public static AssetList initFixedOutLinks(long tm,
                                          int outCapacity,
                                          int size,
                                          int[] overlap,
                                          java.lang.String name,
                                          java.util.List list)

It initializes all fixed outLinks stored in list and returns an instance of AssetList with metaData on each of valid outLinks. The array of overlap determines what outLinks are allowed to be overlapped with others before it. It also initializes non-overlapping outLinks after the last allowed overlap outLinks. For those, it will skip any outLinks with duplicated names.

initOutLinks

public static AssetList initOutLinks(long tm,
                                     int outCapacity,
                                     int size,
                                     int overflow,
                                     java.lang.String name,
                                     java.util.List list)

It initializes all outLinks stored in list and returns an instance of AssetList with metaData on each of outLinks. Any duplicated or malformed outLinks will be ignored. If overflow is positive, OverflowOption will be stored in outInfo at position of overflow.

passthru

public static int passthru(long waitTime,
                           javax.jms.Message msg,
                           XQueue in,
                           XQueue out,
                           long[] outInfo,
                           int option)

puts a msg to out XQ with overflowOption implemented and returns a non-negative number upon success or -1 otherwise

stopRunning

public static void stopRunning(XQueue xq)

getOutstandingSize

public static int getOutstandingSize(XQueue xq,
                                     int begin,
                                     int len)

returns number of outstanding messages for the given xqueue

getReport

public static java.util.Map<java.lang.String,java.lang.Object> getReport(java.lang.String name)

returns the report map of the name from the default container