Class MUXPool

java.lang.Object

org.jpos.q2.QBeanSupport

org.jpos.q2.iso.MUXPool

All Implemented Interfaces:

Configurable, ISOSource, MUX, MUXPoolMBean, QBean, QBeanSupportMBean, QPersist

public class MUXPool
extends QBeanSupport
implements MUX, MUXPoolMBean

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MUXPool.StrategyHandler	A class implementing this interface can be added to a MUXPool to override the classical built-in strategies. It could be added to a MUXPool like this:

Field Summary

Fields

Modifier and Type	Field	Description
static final int	PRIMARY_SECONDARY
static final int	ROUND_ROBIN
static final int	ROUND_ROBIN_WITH_OVERRIDE
static final int	SPLIT_BY_DIVISOR

Fields inherited from class QBeanSupport

cfg, log, scheduledThreadPoolExecutor

Fields inherited from interface QBean

DESTROYED, FAILED, STARTED, STARTING, stateString, STOPPED, STOPPING

Constructor Summary

Constructors

Constructor	Description
MUXPool()

Method Summary

Modifier and Type	Method	Description
protected MUX	firstAvailableMUX(long maxWait)
String[]	getMuxNames()
int	getStrategy()
MUXPool.StrategyHandler	getStrategyHandler()
protected void	initHandler(org.jdom2.Element e)
void	initService()
boolean	isConnected()
protected MUX	nextAvailableMUX(int mnumber, long maxWait)
ISOMsg	request(ISOMsg m, long timeout)	Sends a message to remote host and wait for response
void	request(ISOMsg m, long timeout, ISOResponseListener r, Object handBack)	Sends a message to remote host in async way
void	send(ISOMsg m)	sends (or hands back) an ISOMsg
void	stopService()

Methods inherited from class QBeanSupport

addAttr, close, createElement, destroy, destroyService, getAttrs, getAttrs, getConfiguration, getDump, getFactory, getLoader, getLoaderURLS, getLog, getLogger, getName, getPersist, getProperties, getProperty, getRealm, getScheduledThreadPoolExecutor, getServer, getState, getStateAsString, init, isModified, running, setAttr, setConfiguration, setLogger, setModified, setName, setPersist, setProperty, setRealm, setServer, setState, start, startService, stop

Methods inherited from class Object

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

Methods inherited from interface QBean

destroy, getState, getStateAsString, init, start, stop

Methods inherited from interface QBeanSupportMBean

getDump, getLoader, getLoaderURLS, getLogger, getName, getRealm, getServer, setLogger, setName, setPersist, setRealm, setServer

Methods inherited from interface QPersist

getPersist, isModified

Field Details

PRIMARY_SECONDARY

public static final int PRIMARY_SECONDARY

See Also:

• Constant Field Values

ROUND_ROBIN

public static final int ROUND_ROBIN

See Also:

• Constant Field Values

ROUND_ROBIN_WITH_OVERRIDE

public static final int ROUND_ROBIN_WITH_OVERRIDE

See Also:

• Constant Field Values

SPLIT_BY_DIVISOR

public static final int SPLIT_BY_DIVISOR

See Also:

• Constant Field Values

Constructor Details

MUXPool

public MUXPool()

Method Details

initService

public void initService()
                 throws ConfigurationException

Overrides:

initService in class QBeanSupport

Throws:

ConfigurationException

stopService

public void stopService()

Overrides:

stopService in class QBeanSupport

initHandler

protected void initHandler(org.jdom2.Element e)
                    throws ConfigurationException

Throws:

ConfigurationException

request

public ISOMsg request(ISOMsg m,
 long timeout)
               throws ISOException

Description copied from interface: MUX

Sends a message to remote host and wait for response

Specified by:

request in interface MUX

Parameters:

m - message to send

timeout - time to wait for a message

Returns:

received message or null

Throws:

ISOException

request

public void request(ISOMsg m,
 long timeout,
 ISOResponseListener r,
 Object handBack)
             throws ISOException

Description copied from interface: MUX

Sends a message to remote host in async way

Specified by:

request in interface MUX

Parameters:

m - message to send

timeout - time to wait for the response

r - reference to response listener

handBack - optional handback to be given to reponse listener

Throws:

ISOException

send

public void send(ISOMsg m)
          throws ISOException,
IOException

Description copied from interface: ISOSource

sends (or hands back) an ISOMsg

Specified by:

send in interface ISOSource

Parameters:

m - the Message to be sent

Throws:

ISOException

IOException

firstAvailableMUX

protected MUX firstAvailableMUX(long maxWait)

nextAvailableMUX

protected MUX nextAvailableMUX(int mnumber,
 long maxWait)

getMuxNames

public String[] getMuxNames()

Specified by:

getMuxNames in interface MUXPoolMBean

getStrategy

public int getStrategy()

Specified by:

getStrategy in interface MUXPoolMBean

getStrategyHandler

public MUXPool.StrategyHandler getStrategyHandler()

isConnected

public boolean isConnected()

Specified by:

isConnected in interface ISOSource

Returns:

true if source is connected and usable