Class ISOServer

java.lang.Object

java.util.Observable

org.jpos.iso.ISOServer

All Implemented Interfaces:

Runnable, Observer, Configurable, ISOServerMBean, ISOServerSocketFactory, Loggeable, LogSource

public class ISOServer
extends Observable
implements LogSource, Runnable, Observer, ISOServerMBean, Configurable, Loggeable, ISOServerSocketFactory

Accept ServerChannel sessions and forwards them to ISORequestListeners

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	ISOServer.Session

Field Summary

Fields

Modifier and Type	Field	Description
protected Configuration	cfg
protected Collection	clientIncomingFilters
protected Collection	clientOutgoingFilters
protected ISOChannel	clientSideChannel
static final int	DEFAULT_MAX_SESSIONS
protected boolean	ignoreISOExceptions
static final String	LAST
protected long	lastTxn
protected List<ISORequestListener>	listeners
protected Logger	logger
protected String	realm
protected String	realmChannel
protected List<ISOServerEventListener>	serverListeners
protected ISOServerSocketFactory	socketFactory

Constructor Summary

Constructors

Constructor	Description
ISOServer(int port, ServerChannel clientSide, int maxSessions)

Method Summary

Modifier and Type	Method	Description
void	addISORequestListener(ISORequestListener l)	add an ISORequestListener
void	addServerEventListener(ISOServerEventListener listener)
ServerSocket	createServerSocket(int port)	Create a server socket on the specified port (port 0 indicates an anonymous port).
protected ISOServer.Session	createSession(ServerChannel channel)
void	dump(PrintStream p, String indent)
void	fireEvent(EventObject event)
int	getActiveConnections()
int	getConnectionCount()
int	getConnections()
int[]	getCounters()
String	getCountersAsString()
String	getCountersAsString(String isoChannelName)
long	getIdleTimeInMillis()
ISOChannel	getISOChannel(String name)
String	getISOChannelNames()
ISOChannel	getLastConnectedISOChannel()
long	getLastTxnTimestampInMillis()
Logger	getLogger()
String	getName()
int	getPort()
String	getRealm()
int	getRXCounter()
static ISOServer	getServer(String name)
ISOServerSocketFactory	getSocketFactory()	Gets the ISOClientSocketFactory (may be null)
int	getTXCounter()
void	removeISORequestListener(ISORequestListener l)	remove an ISORequestListener
void	removeServerEventListener(ISOServerEventListener listener)
void	resetCounters()
void	run()
void	setConfiguration(Configuration cfg)
void	setLogger(Logger logger, String realm)
void	setName(String name)	associates this ISOServer with a name using NameRegistrar
void	setSocketFactory(ISOServerSocketFactory socketFactory)	Sets the specified Socket Factory to create sockets
void	shutdown()	Shutdown this server
void	update(Observable o, Object arg)

Methods inherited from class Observable

addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged

Methods inherited from class Object

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

Methods inherited from interface Loggeable

dump

Field Details

clientSideChannel

protected ISOChannel clientSideChannel

clientOutgoingFilters

protected Collection clientOutgoingFilters

clientIncomingFilters

protected Collection clientIncomingFilters

listeners

protected List<ISORequestListener> listeners

DEFAULT_MAX_SESSIONS

public static final int DEFAULT_MAX_SESSIONS

See Also:

• Constant Field Values

LAST

public static final String LAST

See Also:

• Constant Field Values

lastTxn

protected long lastTxn

logger

protected Logger logger

realm

protected String realm

realmChannel

protected String realmChannel

socketFactory

protected ISOServerSocketFactory socketFactory

cfg

protected Configuration cfg

ignoreISOExceptions

protected boolean ignoreISOExceptions

serverListeners

protected List<ISOServerEventListener> serverListeners

Constructor Details

ISOServer

public ISOServer(int port,
 ServerChannel clientSide,
 int maxSessions)

Parameters:

port - port to listen

clientSide - client side ISOChannel, used as a "clonable template" to accept new connections

Method Details

setConfiguration

public void setConfiguration(Configuration cfg)
                      throws ConfigurationException

Specified by:

setConfiguration in interface Configurable

Parameters:

cfg - Configuration object

Throws:

ConfigurationException

addISORequestListener

public void addISORequestListener(ISORequestListener l)

add an ISORequestListener

Parameters:

l - request listener to be added

See Also:

• ISORequestListener

removeISORequestListener

public void removeISORequestListener(ISORequestListener l)

remove an ISORequestListener

Parameters:

l - a request listener to be removed

See Also:

• ISORequestListener

shutdown

public void shutdown()

Shutdown this server

createServerSocket

public ServerSocket createServerSocket(int port)
                                throws IOException

Description copied from interface: ISOServerSocketFactory

Create a server socket on the specified port (port 0 indicates an anonymous port).

Specified by:

createServerSocket in interface ISOServerSocketFactory

Parameters:

port - the port number

Returns:

the server socket on the specified port

Throws:

IOException - should an I/O error occur

createSession

protected ISOServer.Session createSession(ServerChannel channel)

run

public void run()

Specified by:

run in interface Runnable

setName

public void setName(String name)

associates this ISOServer with a name using NameRegistrar

Parameters:

name - name to register

See Also:

• NameRegistrar

getServer

public static ISOServer getServer(String name)
                           throws NameRegistrar.NotFoundException

Returns:

ISOServer instance with given name.

Throws:

NameRegistrar.NotFoundException

See Also:

• NameRegistrar

getName

public String getName()

Returns:

this ISOServer's name ("" if no name was set)

setLogger

public void setLogger(Logger logger,
 String realm)

Specified by:

setLogger in interface LogSource

getRealm

public String getRealm()

Specified by:

getRealm in interface LogSource

getLogger

public Logger getLogger()

Specified by:

getLogger in interface LogSource

update

public void update(Observable o,
 Object arg)

Specified by:

update in interface Observer

getSocketFactory

public ISOServerSocketFactory getSocketFactory()

Gets the ISOClientSocketFactory (may be null)

Since:

1.3.3

See Also:

• ISOClientSocketFactory

setSocketFactory

public void setSocketFactory(ISOServerSocketFactory socketFactory)

Sets the specified Socket Factory to create sockets

Parameters:

socketFactory - the ISOClientSocketFactory

Since:

1.3.3

See Also:

• ISOClientSocketFactory

getPort

public int getPort()

Specified by:

getPort in interface ISOServerMBean

resetCounters

public void resetCounters()

Specified by:

resetCounters in interface ISOServerMBean

getConnectionCount

public int getConnectionCount()

Specified by:

getConnectionCount in interface ISOServerMBean

Returns:

number of connections accepted by this server

getLastConnectedISOChannel

public ISOChannel getLastConnectedISOChannel()

Returns:

most recently connected ISOChannel or null

getISOChannel

public ISOChannel getISOChannel(String name)

Returns:

ISOChannel under the given name

getISOChannelNames

public String getISOChannelNames()

Specified by:

getISOChannelNames in interface ISOServerMBean

getCountersAsString

public String getCountersAsString()

getCounters

public int[] getCounters()

getTXCounter

public int getTXCounter()

Specified by:

getTXCounter in interface ISOServerMBean

getRXCounter

public int getRXCounter()

Specified by:

getRXCounter in interface ISOServerMBean

getConnections

public int getConnections()

getLastTxnTimestampInMillis

public long getLastTxnTimestampInMillis()

Specified by:

getLastTxnTimestampInMillis in interface ISOServerMBean

getIdleTimeInMillis

public long getIdleTimeInMillis()

Specified by:

getIdleTimeInMillis in interface ISOServerMBean

getCountersAsString

public String getCountersAsString(String isoChannelName)

Specified by:

getCountersAsString in interface ISOServerMBean

dump

public void dump(PrintStream p,
 String indent)

Specified by:

dump in interface Loggeable

addServerEventListener

public void addServerEventListener(ISOServerEventListener listener)

removeServerEventListener

public void removeServerEventListener(ISOServerEventListener listener)

fireEvent

public void fireEvent(EventObject event)

getActiveConnections

public int getActiveConnections()