Class QMUXProxy

java.lang.Object

org.jpos.q2.iso.QMUXProxy

All Implemented Interfaces:

Remote, Configurable, RemoteQMUX

public class QMUXProxy
extends Object
implements RemoteQMUX, Configurable

RMI QMUX Proxy

Since:

1.4.9

Constructor Summary

Constructors

Constructor	Description
QMUXProxy(QMUX qmux)	Constructs an RMI-exported proxy for the given QMUX.

Method Summary

Modifier and Type	Method	Description
boolean	isConnected()	Indicates whether the underlying MUX is currently connected.
ISOMsg	request(ISOMsg m, long timeout)	Sends m and blocks for up to timeout ms waiting for a matching response.
void	request(ISOMsg m, long timeout, ISOResponseListener rl, Object handBack)	Sends m asynchronously, dispatching the response (or expiration) to r.
void	setConfiguration(Configuration cfg)	Configures this object with the supplied Configuration.

Methods inherited from class Object

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

Constructor Details

QMUXProxy

public QMUXProxy(QMUX qmux)
          throws RemoteException

Constructs an RMI-exported proxy for the given QMUX.

Parameters:

qmux - underlying MUX exposed over RMI

Throws:

RemoteException - if RMI export fails

Method Details

isConnected

public boolean isConnected()

Description copied from interface: RemoteQMUX

Indicates whether the underlying MUX is currently connected.

Specified by:

isConnected in interface RemoteQMUX

Returns:

true if connected

request

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

Description copied from interface: RemoteQMUX

Sends m and blocks for up to timeout ms waiting for a matching response.

Specified by:

request in interface RemoteQMUX

Parameters:

m - message to send

timeout - time to wait for a message

Returns:

received message or null

Throws:

ISOException - on pack/unpack error

request

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

Description copied from interface: RemoteQMUX

Sends m asynchronously, dispatching the response (or expiration) to r.

Specified by:

request in interface RemoteQMUX

Parameters:

m - message to send

timeout - time to wait for a response

rl - response listener notified on success or expiration

handBack - opaque token relayed back to r

Throws:

ISOException - on pack/unpack error

setConfiguration

public void setConfiguration(Configuration cfg)
                      throws ConfigurationException

Description copied from interface: Configurable

Configures this object with the supplied Configuration.

Specified by:

setConfiguration in interface Configurable

Parameters:

cfg - Configuration object

Throws:

ConfigurationException - if the configuration is invalid