Class LoopbackChannel

java.lang.Object

java.util.Observable

org.jpos.iso.FilteredBase

org.jpos.iso.channel.LoopbackChannel

All Implemented Interfaces:

Cloneable, FilteredChannel, ISOChannel, ISOSource, LogSource

public class LoopbackChannel
extends FilteredBase
implements LogSource

In-memory ISO channel that loops messages back through a BlockingQueue, useful for testing without external network resources.

Field Summary

Fields inherited from class FilteredBase

incomingFilters, outgoingFilters

Modifier and Type	Field	Description
protected Vector	incomingFilters	Filters applied to inbound and outbound traffic respectively.
protected Vector	outgoingFilters	Filters applied to inbound and outbound traffic respectively.

Fields inherited from interface ISOChannel

CONNECT, RX, SIZEOF_CNT, TX

Modifier and Type	Field	Description
static final int	CONNECT	Counter index for connection events.
static final int	RX	Counter index for received messages.
static final int	SIZEOF_CNT	Number of counters maintained by this channel.
static final int	TX	Counter index for transmitted messages.

Constructor Summary

Constructors

Constructor	Description
LoopbackChannel()	Default constructor.

Method Summary

Modifier and Type	Method	Description
void	connect()	Connects ISOChannel
void	disconnect()	disconnects ISOChannel
int[]	getCounters()	Returns the live counter array (transmitted/received tallies).
Logger	getLogger()	Returns the Logger associated with this source.
String	getName()	Returns this channel's registered name.
ISOPackager	getPackager()	Returns the packager configured on this channel.
String	getRealm()	Returns the log realm associated with this source.
boolean	isConnected()	Indicates whether this source is currently connected and able to send messages.
ISOMsg	receive()	Receives an ISOMsg
void	reconnect()	Reconnect channel
void	resetCounters()	Resets the connect/transmit/receive counters to zero.
void	send(byte[] b)	sends a byte[] over the TCP/IP session
void	send(ISOMsg m)	sends an ISOMsg over the TCP/IP session
void	setLogger(Logger logger, String realm)	Attaches a Logger and realm to this log source.
void	setName(String name)	associates this ISOChannel with a name on NameRegistrar
void	setPackager(ISOPackager packager)	setPackager is optional on LoopbackChannel, it is used for debugging/formating purposes only
void	setUsable(boolean usable)	Marks this channel as usable or not; a non-usable channel will not accept messages.

Methods inherited from class FilteredBase

addFilter, addIncomingFilter, addOutgoingFilter, applyIncomingFilters, applyOutgoingFilters, clone, getIncomingFilters, getOutgoingFilters, removeFilter, removeIncomingFilter, removeOutgoingFilter, setIncomingFilters, setOutgoingFilters

Modifier and Type	Method	Description
void	addFilter(ISOFilter filter)	Adds a filter to both incoming and outgoing chains.
void	addIncomingFilter(ISOFilter filter)	Adds a filter to the incoming filter chain.
void	addOutgoingFilter(ISOFilter filter)	Adds a filter to the outgoing filter chain.
protected ISOMsg	applyIncomingFilters(ISOMsg m, LogEvent evt)	Runs every incoming filter against m and notifies observers of the result.
protected ISOMsg	applyOutgoingFilters(ISOMsg m, LogEvent evt)	Runs every outgoing filter against m and notifies observers of the result.
Object	clone()	Returns a clone of this channel.
Collection	getIncomingFilters()	Returns all filters in the incoming filter chain.
Collection	getOutgoingFilters()	Returns all filters in the outgoing filter chain.
void	removeFilter(ISOFilter filter)	Removes a filter from both incoming and outgoing chains.
void	removeIncomingFilter(ISOFilter filter)	Removes a filter from the incoming filter chain.
void	removeOutgoingFilter(ISOFilter filter)	Removes a filter from the outgoing filter chain.
void	setIncomingFilters(Collection filters)	Replaces the entire incoming filter chain with the given collection.
void	setOutgoingFilters(Collection filters)	Replaces the entire outgoing filter chain with the given collection.

Methods inherited from class Observable

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

Methods inherited from class Object

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

Constructor Details

LoopbackChannel

public LoopbackChannel()

Default constructor.

Method Details

setPackager

public void setPackager(ISOPackager packager)

setPackager is optional on LoopbackChannel, it is used for debugging/formating purposes only

Specified by:

setPackager in interface ISOChannel

Parameters:

packager - an ISOPackager

connect

public void connect()

Description copied from interface: ISOChannel

Connects ISOChannel

Specified by:

connect in interface ISOChannel

disconnect

public void disconnect()

disconnects ISOChannel

Specified by:

disconnect in interface ISOChannel

reconnect

public void reconnect()

Description copied from interface: ISOChannel

Reconnect channel

Specified by:

reconnect in interface ISOChannel

isConnected

public boolean isConnected()

Description copied from interface: ISOSource

Indicates whether this source is currently connected and able to send messages.

Specified by:

isConnected in interface ISOChannel

Specified by:

isConnected in interface ISOSource

Returns:

true if Channel is connected and usable

send

public void send(ISOMsg m)
          throws IOException,
ISOException

Description copied from interface: ISOChannel

sends an ISOMsg over the TCP/IP session

Specified by:

send in interface ISOChannel

Specified by:

send in interface ISOSource

Parameters:

m - the Message to be sent

Throws:

IOException - on I/O failure

ISOException - on ISO packing/unpacking failure

send

public void send(byte[] b)
          throws IOException,
ISOException

Description copied from interface: ISOChannel

sends a byte[] over the TCP/IP session

Specified by:

send in interface ISOChannel

Parameters:

b - the byte array to be sent

Throws:

IOException - on I/O failure

ISOException - on ISO packing/unpacking failure

receive

public ISOMsg receive()
               throws IOException,
ISOException

Description copied from interface: ISOChannel

Receives an ISOMsg

Specified by:

receive in interface ISOChannel

Returns:

the Message received

Throws:

IOException - on I/O failure

ISOException - on ISO packing/unpacking failure

setUsable

public void setUsable(boolean usable)

Description copied from interface: ISOChannel

Marks this channel as usable or not; a non-usable channel will not accept messages.

Specified by:

setUsable in interface ISOChannel

Parameters:

usable - - usable state

getCounters

public int[] getCounters()

Returns the live counter array (transmitted/received tallies).

Returns:

counter array as managed by this channel

setName

public void setName(String name)

Description copied from interface: ISOChannel

associates this ISOChannel with a name on NameRegistrar

Specified by:

setName in interface ISOChannel

Parameters:

name - name to register

See Also:

• NameRegistrar

getName

public String getName()

Description copied from interface: ISOChannel

Returns this channel's registered name.

Specified by:

getName in interface ISOChannel

Returns:

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

getPackager

public ISOPackager getPackager()

Returns the packager configured on this channel.

Specified by:

getPackager in interface ISOChannel

Returns:

null; the loopback channel has no packager because messages are queued as objects

resetCounters

public void resetCounters()

Resets the connect/transmit/receive counters to zero.

setLogger

public void setLogger(Logger logger,
 String realm)

Description copied from interface: LogSource

Attaches a Logger and realm to this log source.

Specified by:

setLogger in interface LogSource

Parameters:

logger - the logger to use

realm - the log realm (diagnostic label)

getRealm

public String getRealm()

Description copied from interface: LogSource

Returns the log realm associated with this source.

Specified by:

getRealm in interface LogSource

Returns:

log realm

getLogger

public Logger getLogger()

Description copied from interface: LogSource

Returns the Logger associated with this source.

Specified by:

getLogger in interface LogSource

Returns:

the Logger