Class QMUX

java.lang.Object

org.jpos.q2.QBeanSupport

org.jpos.q2.iso.QMUX

All Implemented Interfaces:

Configurable, ISOSource, MUX, QMUXMBean, QBean, QBeanSupportMBean, QPersist, SpaceListener, Loggeable, MetricsProvider

public class QMUX
extends QBeanSupport
implements SpaceListener, MUX, QMUXMBean, Loggeable, MetricsProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	QMUX.AsyncRequest

Field Summary

Fields

Modifier and Type	Field	Description
protected String	ignorerc
protected String	in
protected String[]	key
protected String[]	mtiMapping
protected String	out
protected String[]	ready
protected LocalSpace	sp
protected String	unhandled

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
QMUX()

Method Summary

Modifier and Type	Method	Description
void	addISORequestListener(ISORequestListener l)
void	destroyService()
void	dump(PrintStream p, String indent)
String	getCountersAsString()
long	getIdleTimeInMillis()
String	getInQueue()
String	getKey(ISOMsg m)
long	getLastTxnTimestampInMillis()
Metrics	getMetrics()
static MUX	getMUX(String name)
String	getOutQueue()
String[]	getReadyIndicatorNames()
int	getRXCounter()
int	getRXExpired()
int	getRXForwarded()
int	getRXPending()
int	getRXUnhandled()
Space	getSpace()
int	getTXCounter()
int	getTXExpired()
int	getTXPending()
String	getUnhandledQueue()
void	initService()
boolean	isConnected()
protected boolean	isNotifyEligible(ISOMsg msg)
void	notify(Object k, Object value)	Called by Space implementation whenever an object with the given key is being placed in the Space.
protected void	processUnhandled(ISOMsg m)
boolean	removeISORequestListener(ISORequestListener l)
ISOMsg	request(ISOMsg m, long timeout)	Sends a message to remote host and wait for response
void	request(ISOMsg m, long timeout, ISOResponseListener rl, Object handBack)	Sends a message to remote host in async way
void	resetCounters()
void	send(ISOMsg m)	sends (or hands back) an ISOMsg
void	setInQueue(String in)
void	setOutQueue(String out)
void	setUnhandledQueue(String unhandled)
void	startService()
void	stopService()

Methods inherited from class QBeanSupport

addAttr, close, createElement, destroy, 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, stop

Methods inherited from class Object

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

Methods inherited from interface Loggeable

dump

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

sp

protected LocalSpace sp

in

protected String in

out

protected String out

unhandled

protected String unhandled

ready

protected String[] ready

key

protected String[] key

ignorerc

protected String ignorerc

mtiMapping

protected String[] mtiMapping

Constructor Details

QMUX

public QMUX()

Method Details

initService

public void initService()
                 throws ConfigurationException

Overrides:

initService in class QBeanSupport

Throws:

ConfigurationException

startService

public void startService()

Overrides:

startService in class QBeanSupport

stopService

public void stopService()

Overrides:

stopService in class QBeanSupport

destroyService

public void destroyService()

Overrides:

destroyService in class QBeanSupport

getMUX

public static MUX getMUX(String name)
                  throws NameRegistrar.NotFoundException

Returns:

MUX with name using NameRegistrar

Throws:

NameRegistrar.NotFoundException

See Also:

• NameRegistrar

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 - amount of time in millis to wait for a response

Returns:

response or null

Throws:

ISOException

request

public void request(ISOMsg m,
 long timeout,
 ISOResponseListener rl,
 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

rl - reference to response listener

handBack - optional handback to be given to reponse listener

Throws:

ISOException

isNotifyEligible

protected boolean isNotifyEligible(ISOMsg msg)

notify

public void notify(Object k,
 Object value)

Description copied from interface: SpaceListener

Called by Space implementation whenever an object with the given key is being placed in the Space.

Specified by:

notify in interface SpaceListener

Parameters:

k - Object's key

value - Object's value

getKey

public String getKey(ISOMsg m)
              throws ISOException

Throws:

ISOException

getMetrics

public Metrics getMetrics()

Specified by:

getMetrics in interface MetricsProvider

setInQueue

public void setInQueue(String in)

Specified by:

setInQueue in interface QMUXMBean

getInQueue

public String getInQueue()

Specified by:

getInQueue in interface QMUXMBean

setOutQueue

public void setOutQueue(String out)

Specified by:

setOutQueue in interface QMUXMBean

getOutQueue

public String getOutQueue()

Specified by:

getOutQueue in interface QMUXMBean

getSpace

public Space getSpace()

setUnhandledQueue

public void setUnhandledQueue(String unhandled)

Specified by:

setUnhandledQueue in interface QMUXMBean

getUnhandledQueue

public String getUnhandledQueue()

Specified by:

getUnhandledQueue in interface QMUXMBean

getReadyIndicatorNames

public String[] getReadyIndicatorNames()

addISORequestListener

public void addISORequestListener(ISORequestListener l)

removeISORequestListener

public boolean removeISORequestListener(ISORequestListener l)

resetCounters

public void resetCounters()

Specified by:

resetCounters in interface QMUXMBean

getCountersAsString

public String getCountersAsString()

Specified by:

getCountersAsString in interface QMUXMBean

getTXCounter

public int getTXCounter()

Specified by:

getTXCounter in interface QMUXMBean

getRXCounter

public int getRXCounter()

Specified by:

getRXCounter in interface QMUXMBean

getTXExpired

public int getTXExpired()

Specified by:

getTXExpired in interface QMUXMBean

getTXPending

public int getTXPending()

Specified by:

getTXPending in interface QMUXMBean

getRXExpired

public int getRXExpired()

Specified by:

getRXExpired in interface QMUXMBean

getRXPending

public int getRXPending()

Specified by:

getRXPending in interface QMUXMBean

getRXUnhandled

public int getRXUnhandled()

Specified by:

getRXUnhandled in interface QMUXMBean

getRXForwarded

public int getRXForwarded()

Specified by:

getRXForwarded in interface QMUXMBean

getLastTxnTimestampInMillis

public long getLastTxnTimestampInMillis()

Specified by:

getLastTxnTimestampInMillis in interface QMUXMBean

getIdleTimeInMillis

public long getIdleTimeInMillis()

Specified by:

getIdleTimeInMillis in interface QMUXMBean

processUnhandled

protected void processUnhandled(ISOMsg m)

send

public void send(ISOMsg m)
          throws IOException,
ISOException

sends (or hands back) an ISOMsg

Specified by:

send in interface ISOSource

Parameters:

m - the Message to be sent

Throws:

IOException

ISOException

isConnected

public boolean isConnected()

Specified by:

isConnected in interface ISOSource

Returns:

true if source is connected and usable

dump

public void dump(PrintStream p,
 String indent)

Specified by:

dump in interface Loggeable