Class OneShotChannelAdaptor

java.lang.Object

org.jpos.q2.QBeanSupport

org.jpos.q2.iso.OneShotChannelAdaptor

All Implemented Interfaces:

Configurable, Channel, OneShotChannelAdaptorMBean, QBean, QBeanSupportMBean, QPersist

public class OneShotChannelAdaptor
extends QBeanSupport
implements OneShotChannelAdaptorMBean, Channel

OneShotChannelAdaptor connects and disconnects a channel for every message exchange.

Example qbean:

<client class="org.jpos.q2.iso.OneShotChannelAdaptor" logger="Q2" name="channel-adaptor">
<channel ...
...
...
</channel>
<max-connections>5</max-connections>
<max-connect-attempts>15</max-connect-attempts>
<in>send</in>
<out>receive</out>
</client>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	OneShotChannelAdaptor.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
OneShotChannelAdaptor()

Method Summary

Modifier and Type	Method	Description
void	destroyService()
String	getHost()
String	getInQueue()
String	getOutQueue()
int	getPort()
String	getSocketFactory()
void	initAdaptor()
ISOMsg	receive()	Receive message
ISOMsg	receive(long timeout)	Receive message
void	send(ISOMsg m)	Queue a message to be transmitted by this adaptor
void	send(ISOMsg m, long timeout)	Queue a message to be transmitted by this adaptor
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, initService, 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

OneShotChannelAdaptor

public OneShotChannelAdaptor()

Method Details

initAdaptor

public void initAdaptor()

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

send

public void send(ISOMsg m)

Queue a message to be transmitted by this adaptor

Specified by:

send in interface Channel

Parameters:

m - message to send

send

public void send(ISOMsg m,
 long timeout)

Queue a message to be transmitted by this adaptor

Parameters:

m - message to send

timeout - in millis

receive

public ISOMsg receive()

Receive message

Specified by:

receive in interface Channel

Returns:

received message

receive

public ISOMsg receive(long timeout)

Receive message

Specified by:

receive in interface Channel

Parameters:

timeout - time to wait for an incoming message

Returns:

received message or null

setInQueue

public void setInQueue(String in)

Specified by:

setInQueue in interface OneShotChannelAdaptorMBean

getInQueue

public String getInQueue()

Specified by:

getInQueue in interface OneShotChannelAdaptorMBean

setOutQueue

public void setOutQueue(String out)

Specified by:

setOutQueue in interface OneShotChannelAdaptorMBean

getOutQueue

public String getOutQueue()

Specified by:

getOutQueue in interface OneShotChannelAdaptorMBean

setHost

public void setHost(String host)

Specified by:

setHost in interface OneShotChannelAdaptorMBean

getHost

public String getHost()

Specified by:

getHost in interface OneShotChannelAdaptorMBean

setPort

public void setPort(int port)

Specified by:

setPort in interface OneShotChannelAdaptorMBean

getPort

public int getPort()

Specified by:

getPort in interface OneShotChannelAdaptorMBean

setSocketFactory

public void setSocketFactory(String sFac)

Specified by:

setSocketFactory in interface OneShotChannelAdaptorMBean

getSocketFactory

public String getSocketFactory()

Specified by:

getSocketFactory in interface OneShotChannelAdaptorMBean