Class FSDChannel

java.lang.Object

java.util.Observable

org.jpos.iso.BaseChannel

org.jpos.iso.channel.NACChannel

org.jpos.iso.channel.FSDChannel

All Implemented Interfaces:

Cloneable, Configurable, ExceptionHandlerAware, BaseChannelMBean, ClientChannel, FactoryChannel, FilteredChannel, ISOChannel, ISOSource, ServerChannel, ISOMsgMetrics.Source, LogSource

public class FSDChannel
extends NACChannel

Field Summary

Fields inherited from class BaseChannel

cnt, header, incomingFilters, logger, originalRealm, outgoingFilters, overrideHeader, packager, realm, serverIn, serverInLock, serverOut, serverOutLock, serverSocket, socketFactory, usable

Fields inherited from interface ISOChannel

CONNECT, RX, SIZEOF_CNT, TX

Constructor Summary

Constructors

Constructor	Description
FSDChannel()

Method Summary

Modifier and Type	Method	Description
ISOMsg	createMsg()	support old factory method name for backward compatibility
protected int	getMessageLength()
void	send(ISOMsg m)	Sends the specified ISOMsg over this ISOChannel.
void	setConfiguration(Configuration cfg)	Implements Configurable Properties: host - destination host (if ClientChannel) port - port number (if ClientChannel) local-iface - local interfase to use (if ClientChannel) local-port - local port to bind (if ClientChannel) (host not present indicates a ServerChannel)

Methods inherited from class NACChannel

sendMessageHeader, sendMessageLength, setHeader

Methods inherited from class BaseChannel

accept, addFilter, addFilter, addIncomingFilter, addOutgoingFilter, applyIncomingFilters, applyIncomingFilters, applyOutgoingFilters, applyTimeout, clone, closeSocket, connect, connect, createISOMsg, disconnect, getBytes, getChannel, getConfiguration, getCounters, getDynamicHeader, getDynamicPackager, getDynamicPackager, getDynamicPackager, getExceptionHandlers, getHeader, getHeaderLength, getHeaderLength, getHeaderLength, getHost, getIncomingFilters, getISOMsgMetrics, getLogger, getMaxPacketLength, getMessage, getMessageTrailer, getMessageTrailler, getName, getOriginalRealm, getOutgoingFilters, getPackager, getPort, getRealm, getServerSocket, getSocket, getSocketFactory, getSoLingerSeconds, getTimeout, incrementMsgInCounter, incrementMsgOutCounter, isConnected, isExpectKeepAlive, isOverrideHeader, isRejected, isSoLingerOn, newSocket, newSocket, pack, postConnectHook, readHeader, receive, reconnect, removeFilter, removeFilter, removeIncomingFilter, removeOutgoingFilter, resetCounters, send, sendKeepAlive, sendMessage, sendMessageTrailer, sendMessageTrailler, sendMessageTrailler, setHeader, setHost, setHost, setIncomingFilters, setISOMsgMetrics, setLocalAddress, setLogger, setMaxPacketLength, setName, setOutgoingFilters, setOverrideHeader, setPackager, setPort, setServerSocket, setSocketFactory, setSoLinger, setTimeout, setUsable, shouldIgnore, streamReceive, unpack

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

Methods inherited from interface ExceptionHandlerAware

addHandler, addHandler, handle, removeHandler, removeHandler, removeHandlers

Constructor Details

FSDChannel

public FSDChannel()

Method Details

createMsg

public ISOMsg createMsg()

Description copied from class: BaseChannel

support old factory method name for backward compatibility

Overrides:

createMsg in class BaseChannel

Returns:

newly created ISOMsg

setConfiguration

public void setConfiguration(Configuration cfg)
                      throws ConfigurationException

Description copied from class: BaseChannel

Implements Configurable
Properties:

• host - destination host (if ClientChannel)
• port - port number (if ClientChannel)
• local-iface - local interfase to use (if ClientChannel)
• local-port - local port to bind (if ClientChannel)

(host not present indicates a ServerChannel)

Specified by:

setConfiguration in interface Configurable

Overrides:

setConfiguration in class NACChannel

Parameters:

cfg - Configuration

Throws:

ConfigurationException

send

public void send(ISOMsg m)
          throws IOException,
ISOException

Description copied from class: BaseChannel

Sends the specified ISOMsg over this ISOChannel.

This method performs the following steps:

• Verifies the channel is connected.
• Sets the message direction to ISOMsg.OUTGOING.
• Retrieves and sets a dynamic packager for the message.
• Applies all registered outgoing filters, allowing them to modify or veto the message.
• Packs the message and writes its length, header, body, and trailer to the underlying stream, protected by a locking mechanism to ensure thread safety.
• Flushes the output stream and increments message counters.
• Notifies observers of the sent message.
• Logs both the message and the send operation through ChannelEvent and LogEvent.

If a ISOFilter.VetoException is thrown by a filter, the message is not sent, and the exception is logged.

Specified by:

send in interface ISOChannel

Specified by:

send in interface ISOSource

Overrides:

send in class BaseChannel

Parameters:

m - the ISO message to be sent. The message will be modified in-place: its direction and packager will be updated, and filters may alter its content.

Throws:

IOException - if the channel is not connected, if the output stream fails, if locking times out, or if an unexpected I/O error occurs.

ISOException - if packing the message fails or other ISO-specific issues occur.

See Also:

• ISOMsg
• ISOPackager
• ISOFilter
• ChannelEvent
• LogEvent

getMessageLength

protected int getMessageLength()
                        throws IOException,
ISOException

Overrides:

getMessageLength in class NACChannel

Throws:

IOException

ISOException