org.jpos.q2.iso

Class OneShotChannelAdaptorMK2

java.lang.Object

org.jpos.q2.QBeanSupport

org.jpos.q2.iso.OneShotChannelAdaptorMK2

All Implemented Interfaces:

java.lang.Runnable, Configurable, Channel, OneShotChannelAdaptorMK2MBean, QBean, QBeanSupportMBean, QPersist

public class OneShotChannelAdaptorMK2
extends QBeanSupport
implements OneShotChannelAdaptorMK2MBean, Channel, java.lang.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 and Description
class	OneShotChannelAdaptorMK2.Worker

Field Summary

Fields inherited from class org.jpos.q2.QBeanSupport

cfg, log, scheduledThreadPoolExecutor

Fields inherited from interface org.jpos.q2.QBean

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

Constructor Summary

Constructors

Constructor and Description
OneShotChannelAdaptorMK2()

Method Summary

Modifier and Type	Method and Description
void	destroyService()
java.lang.String	getHost()
java.lang.String	getInQueue()
java.lang.String	getOutQueue()
int	getPort()
java.lang.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(java.lang.String host)
void	setInQueue(java.lang.String in)
void	setOutQueue(java.lang.String out)
void	setPort(int port)
void	setSocketFactory(java.lang.String sFac)
void	startService()
void	stopService()

Methods inherited from class org.jpos.q2.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 java.lang.Object

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

Methods inherited from interface org.jpos.q2.QBeanSupportMBean

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

Methods inherited from interface org.jpos.q2.QBean

destroy, getState, getStateAsString, init, start, stop

Methods inherited from interface org.jpos.q2.QPersist

getPersist, isModified

Constructor Detail

OneShotChannelAdaptorMK2

public OneShotChannelAdaptorMK2()

Method Detail

initService

protected void initService()
                    throws java.lang.Exception

Overrides:

initService in class QBeanSupport

Throws:

java.lang.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 java.lang.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 java.lang.String getInQueue()

Specified by:

getInQueue in interface OneShotChannelAdaptorMK2MBean

setInQueue

public void setInQueue(java.lang.String in)

Specified by:

setInQueue in interface OneShotChannelAdaptorMK2MBean

getOutQueue

public java.lang.String getOutQueue()

Specified by:

getOutQueue in interface OneShotChannelAdaptorMK2MBean

setOutQueue

public void setOutQueue(java.lang.String out)

Specified by:

setOutQueue in interface OneShotChannelAdaptorMK2MBean

getHost

public java.lang.String getHost()

Specified by:

getHost in interface OneShotChannelAdaptorMK2MBean

setHost

public void setHost(java.lang.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 java.lang.String getSocketFactory()

Specified by:

getSocketFactory in interface OneShotChannelAdaptorMK2MBean

setSocketFactory

public void setSocketFactory(java.lang.String sFac)

Specified by:

setSocketFactory in interface OneShotChannelAdaptorMK2MBean