Class ChannelAdaptor

java.lang.Object

org.jpos.q2.QBeanSupport

org.jpos.q2.iso.ChannelAdaptor

All Implemented Interfaces:

Configurable, ExceptionHandlerConfigAware, Channel, ChannelAdaptorMBean, QBean, QBeanSupportMBean, QPersist, Loggeable

Direct Known Subclasses:

MultiSessionChannelAdaptor

public class ChannelAdaptor
extends QBeanSupport
implements ChannelAdaptorMBean, Channel, Loggeable, ExceptionHandlerConfigAware

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ChannelAdaptor.Receiver
class	ChannelAdaptor.Sender

Field Summary

Fields

Modifier and Type	Field	Description
protected Space	sp

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

Method Summary

Modifier and Type	Method	Description
protected void	addFilters(FilteredChannel channel, org.jdom2.Element e, QFactory fact)
protected void	append(StringBuilder sb, String name, int value)
protected void	checkConnection()
void	destroyService()
protected void	disconnect()
void	dump(PrintStream p, String indent)
int	getConnectsCounter()
String	getCountersAsString()
String	getHost()
long	getIdleTimeInMillis()
String	getInQueue()
long	getLastTxnTimestampInMillis()
String	getOutQueue()
int	getPort()
long	getReconnectDelay()
int	getRXCounter()
String	getSocketFactory()
int	getTXCounter()
protected Space	grabSpace(org.jdom2.Element e)
protected ISOChannel	initChannel()
void	initService()
protected void	initSpaceAndQueues()
boolean	isConnected()
ISOChannel	newChannel(org.jdom2.Element e, QFactory f)	Parses a <channel> element, returning an ISOChannel
ISOMsg	receive()	Receive message
ISOMsg	receive(long timeout)	Receive message
void	resetCounters()
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	setReconnectDelay(long delay)
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 ExceptionHandlerConfigAware

addExceptionHandlers

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 Space sp

Constructor Details

ChannelAdaptor

public ChannelAdaptor()

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

setReconnectDelay

public void setReconnectDelay(long delay)

Specified by:

setReconnectDelay in interface ChannelAdaptorMBean

getReconnectDelay

public long getReconnectDelay()

Specified by:

getReconnectDelay in interface ChannelAdaptorMBean

setInQueue

public void setInQueue(String in)

Specified by:

setInQueue in interface ChannelAdaptorMBean

getInQueue

public String getInQueue()

Specified by:

getInQueue in interface ChannelAdaptorMBean

setOutQueue

public void setOutQueue(String out)

Specified by:

setOutQueue in interface ChannelAdaptorMBean

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 - 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

isConnected

public boolean isConnected()

Specified by:

isConnected in interface ChannelAdaptorMBean

Returns:

true if channel is connected

getOutQueue

public String getOutQueue()

Specified by:

getOutQueue in interface ChannelAdaptorMBean

newChannel

public ISOChannel newChannel(org.jdom2.Element e,
 QFactory f)
                      throws ConfigurationException

Parses a <channel> element, returning an ISOChannel

Throws:

ConfigurationException

addFilters

protected void addFilters(FilteredChannel channel,
 org.jdom2.Element e,
 QFactory fact)
                   throws ConfigurationException

Throws:

ConfigurationException

initChannel

protected ISOChannel initChannel()
                          throws ConfigurationException

Throws:

ConfigurationException

initSpaceAndQueues

protected void initSpaceAndQueues()
                           throws ConfigurationException

Throws:

ConfigurationException

checkConnection

protected void checkConnection()

disconnect

protected void disconnect()

setHost

public void setHost(String host)

Specified by:

setHost in interface ChannelAdaptorMBean

getHost

public String getHost()

Specified by:

getHost in interface ChannelAdaptorMBean

setPort

public void setPort(int port)

Specified by:

setPort in interface ChannelAdaptorMBean

getPort

public int getPort()

Specified by:

getPort in interface ChannelAdaptorMBean

setSocketFactory

public void setSocketFactory(String sFac)

Specified by:

setSocketFactory in interface ChannelAdaptorMBean

resetCounters

public void resetCounters()

Specified by:

resetCounters in interface ChannelAdaptorMBean

getCountersAsString

public String getCountersAsString()

Specified by:

getCountersAsString in interface ChannelAdaptorMBean

getTXCounter

public int getTXCounter()

Specified by:

getTXCounter in interface ChannelAdaptorMBean

getRXCounter

public int getRXCounter()

Specified by:

getRXCounter in interface ChannelAdaptorMBean

getConnectsCounter

public int getConnectsCounter()

Specified by:

getConnectsCounter in interface ChannelAdaptorMBean

getLastTxnTimestampInMillis

public long getLastTxnTimestampInMillis()

Specified by:

getLastTxnTimestampInMillis in interface ChannelAdaptorMBean

getIdleTimeInMillis

public long getIdleTimeInMillis()

Specified by:

getIdleTimeInMillis in interface ChannelAdaptorMBean

getSocketFactory

public String getSocketFactory()

Specified by:

getSocketFactory in interface ChannelAdaptorMBean

dump

public void dump(PrintStream p,
 String indent)

Specified by:

dump in interface Loggeable

grabSpace

protected Space grabSpace(org.jdom2.Element e)

append

protected void append(StringBuilder sb,
 String name,
 int value)