Class OneShotChannelAdaptorMK2

java.lang.Object

org.jpos.q2.QBeanSupport

org.jpos.q2.iso.OneShotChannelAdaptorMK2

All Implemented Interfaces:

Runnable, Configurable, Channel, OneShotChannelAdaptorMK2MBean, QBean, QBeanSupportMBean, QPersist

public class OneShotChannelAdaptorMK2
extends QBeanSupport
implements OneShotChannelAdaptorMK2MBean, Channel, Runnable

OneShotChannelAdaptorMK2 connects and disconnects a channel for every message exchange. It is similar to OneShotChannelAdaptor but uses a thread pool instead of opening threads statically and supports mux pooling by exposing channel readiness.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	OneShotChannelAdaptorMK2.Worker

Field Summary

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

Method Summary

Modifier and Type	Method	Description
void	destroyService()
String	getHost()
String	getInQueue()
String	getOutQueue()
int	getPort()
String	getSocketFactory()
protected void	initService()
boolean	isConnected()
ISOMsg	receive()
ISOMsg	receive(long timeout)
void	run()
void	send(ISOMsg m)
void	send(ISOMsg m, long timeout)
void	setHost(String host)
void	setInQueue(String in)
void	setOutQueue(String out)
void	setPort(int port)
void	setSocketFactory(String sFac)
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 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

Constructor Details

OneShotChannelAdaptorMK2

public OneShotChannelAdaptorMK2()

Method Details

initService

protected void initService()
                    throws Exception

Overrides:

initService in class QBeanSupport

Throws:

Exception

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

isConnected

public boolean isConnected()

Specified by:

isConnected in interface OneShotChannelAdaptorMK2MBean

run

public void run()

Specified by:

run in interface Runnable

send

public void send(ISOMsg m)

Specified by:

send in interface Channel

Parameters:

m - message to send

send

public void send(ISOMsg m,
 long timeout)

receive

public ISOMsg receive()

Specified by:

receive in interface Channel

Returns:

received message

receive

public ISOMsg receive(long timeout)

Specified by:

receive in interface Channel

Parameters:

timeout - time to wait for a message

Returns:

received message or null

getInQueue

public String getInQueue()

Specified by:

getInQueue in interface OneShotChannelAdaptorMK2MBean

setInQueue

public void setInQueue(String in)

Specified by:

setInQueue in interface OneShotChannelAdaptorMK2MBean

getOutQueue

public String getOutQueue()

Specified by:

getOutQueue in interface OneShotChannelAdaptorMK2MBean

setOutQueue

public void setOutQueue(String out)

Specified by:

setOutQueue in interface OneShotChannelAdaptorMK2MBean

getHost

public String getHost()

Specified by:

getHost in interface OneShotChannelAdaptorMK2MBean

setHost

public void setHost(String host)

Specified by:

setHost in interface OneShotChannelAdaptorMK2MBean

getPort

public int getPort()

Specified by:

getPort in interface OneShotChannelAdaptorMK2MBean

setPort

public void setPort(int port)

Specified by:

setPort in interface OneShotChannelAdaptorMK2MBean

getSocketFactory

public String getSocketFactory()

Specified by:

getSocketFactory in interface OneShotChannelAdaptorMK2MBean

setSocketFactory

public void setSocketFactory(String sFac)

Specified by:

setSocketFactory in interface OneShotChannelAdaptorMK2MBean