Hi Chhil / Mark,
Thank you for your valuable suggestions.I have already took the Response HexaDump message and tried to unpack using ISOMsg.unpack(byte []). The sample application is able to unpack and print the ISO message field wise. But when I use the same response in my original application, it always fails with the above exception. I am pasting the Packager and Channel class code here. Please help me solve this issue.
package com.xx.xxxxx;
import org.jpos.core.Configurable;
import org.jpos.core.Configuration;
import org.jpos.core.ConfigurationException;
import org.jpos.iso.IF_TBASE;
import org.jpos.iso.ISOBasePackager;
import org.jpos.iso.ISOBitMap;
import org.jpos.iso.ISOBitMapPackager;
import org.jpos.iso.ISOComponent;
import org.jpos.iso.ISOException;
import org.jpos.iso.ISOFieldPackager;
import org.jpos.iso.ISOMsg;
import org.jpos.iso.ISOMsgFieldPackager;
import org.jpos.iso.ISOPackager;
import org.jpos.iso.ISOUtil;
import org.jpos.q2.Q2;
import org.jpos.util.Log;
import org.jpos.util.LogEvent;
import org.jpos.util.LogSource;
import org.jpos.util.Logger;
import org.xml.sax.Attributes;
import org.xml.sax.EntityResolver;
import org.xml.sax.InputSource;
import org.xml.sax.SAXException;
import org.xml.sax.SAXParseException;
import org.xml.sax.XMLReader;
import org.xml.sax.helpers.DefaultHandler;
import org.xml.sax.helpers.XMLReaderFactory;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import java.util.Map;
import java.util.Map.Entry;
import java.util.BitSet;
import java.util.Stack;
import java.util.TreeMap;
/**
* <pre>
* XXXXFinalPackager uses an XML config file to describe the layout of an ISOMessage
* The general format is as follows
* <isopackager>
* <isofield
* id="[field id]"
* name="[field name]"
* length="[max field length]"
* class="[org.jpos.iso.IF_*]"
* pad="true|false">
* </isofield>
* ...
* </isopackager>
*
* Fields that contain subfields can be handled as follows
* <isofieldpackager
* id="[field id]"
* name="[field name]"
* length="[field length]"
* class="[org.jpos.iso.IF_*]"
* packager="[org.jpos.iso.packager.*]">
*
* <isofield
* id="[subfield id]"
* name="[subfield name]"
* length="[max subfield length]"
* class="[org.jpos.iso.IF_*]"
* pad="true|false">
* </isofield>
* ...
* </isofieldpackager>
*
* The optional attributes maxValidField, bitmapField and emitBitmap
* are allowed on the isopackager node.
*
* </pre>
* @author Eoin Flood
* @version $Revision$ $Date$
* @see ISOPackager
* @see ISOBasePackager
*/
@SuppressWarnings("unchecked")
public class XXXXFinalPackager
extends ISOBasePackager implements Configurable
{
/* Values copied from ISOBasePackager
These can be changes using attributes on the isopackager node */
private int maxValidField=128;
private boolean emitBitmap=true;
private int bitmapField=1;
private String firstField = null;
private String filename;
private Log log;
public XXXXFinalPackager() throws ISOException
{
super();
log = Log.getLog(Q2.LOGGER_NAME, "XXXXFInalPackager");
}
/**
* Create a XXXXFInalPackager with the field descriptions
* from an XML File
* @param filename The XML field description file
*/
public XXXXFinalPackager(String filename) throws ISOException
{
this.filename = filename;
readFile(filename);
}
/**
* Create a XXXXFinalPackager with the field descriptions
* from an XML InputStream
* @param input The XML field description InputStream
*/
public XXXXFinalPackager(InputStream input) throws ISOException
{
readFile(input);
}
/**
* Packager Configuration.
*
* <ul>
* <li>packager-config
* <li>packager-logger
* <li>packager-realm
* </ul>
*
* @param cfg Configuration
*/
public void setConfiguration (Configuration cfg)
throws ConfigurationException
{
filename = cfg.get("packager-config", null);
if (filename == null)
throw new ConfigurationException("packager-config property cannot be null");
try
{
String loggerName = cfg.get("packager-logger");
if (loggerName != null)
setLogger(Logger.getLogger (loggerName),
cfg.get ("packager-realm"));
readFile(filename);
} catch (ISOException e)
{
throw new ConfigurationException(e.getMessage(), e.fillInStackTrace());
}
}
@Override
protected int getMaxValidField()
{
return maxValidField;
}
@Override
protected boolean emitBitMap()
{
return emitBitmap;
}
@Override
protected ISOFieldPackager getBitMapfieldPackager()
{
return fld[bitmapField];
}
/**
* Parse the field descriptions from an XML file.
*
* <pre>
* Uses the sax parser specified by the system property 'sax.parser'
* The default parser is org.apache.crimson.parser.XMLReaderImpl
* </pre>
* @param filename The XML field description file
*/
public void readFile(String filename) throws ISOException
{
try {
if (filename.startsWith("jar:") && filename.length()>4) {
ClassLoader cl = Thread.currentThread().getContextClassLoader();
readFile(
cl.getResourceAsStream(filename.substring(4))
);
} else {
createXMLReader().parse(filename);
}
}
catch (Exception e) {
throw new ISOException("Error reading " + filename, e);
}
}
/**
* Parse the field descriptions from an XML InputStream.
*
* <pre>
* Uses the sax parser specified by the system property 'sax.parser'
* The default parser is org.apache.crimson.parser.XMLReaderImpl
* </pre>
* @param input The XML field description InputStream
*/
public void readFile(InputStream input) throws ISOException
{
try {
createXMLReader().parse(new InputSource(input));
}
catch (Exception e) {
throw new ISOException(e);
}
}
@Override
public void setLogger (Logger logger, String realm) {
super.setLogger (logger, realm);
if (fld != null) {
for (int i=0; i<fld.length; i++) {
if (fld[i] instanceof ISOMsgFieldPackager) {
Object o = ((ISOMsgFieldPackager)fld[i]).getISOMsgPackager();
if (o instanceof LogSource) {
((LogSource)o).setLogger (logger, realm + "-fld-" + i);
}
}
}
}
}
private XMLReader createXMLReader () throws SAXException {
XMLReader reader;
try {
reader = XMLReaderFactory.createXMLReader();
} catch (SAXException e) {
reader = XMLReaderFactory.createXMLReader (
System.getProperty(
"org.xml.sax.driver",
"org.apache.crimson.parser.XMLReaderImpl"
)
);
}
GenericContentHandler handler = new GenericContentHandler();
reader.setContentHandler(handler);
reader.setErrorHandler(handler);
reader.setEntityResolver(new GenericEntityResolver());
return reader;
}
@Override
public String getDescription () {
StringBuilder sb = new StringBuilder();
sb.append (super.getDescription());
if (filename != null) {
sb.append ('[');
sb.append (filename);
sb.append (']');
}
return sb.toString();
}
protected void setXXXXFinalPackagerParams (Attributes atts)
{
String maxField = atts.getValue("maxValidField");
String emitBmap = atts.getValue("emitBitmap");
String bmapfield = atts.getValue("bitmapField");
firstField = atts.getValue("firstField");
String headerLenStr = atts.getValue("headerLength");
if (maxField != null)
maxValidField = Integer.parseInt(maxField);
if (emitBmap != null)
emitBitmap = Boolean.valueOf(emitBmap);
if (bmapfield != null)
bitmapField = Integer.parseInt(bmapfield);
if (firstField != null)
Integer.parseInt (firstField); // attempt to parse just to
// force an exception if the
// data is not correct.
if (headerLenStr != null)
setHeaderLength(Integer.parseInt(headerLenStr));
}
public static class GenericEntityResolver implements EntityResolver
{
/**
* Allow the application to resolve external entities.
* <p/>
* The strategy we follow is:<p>
* We first check whether the DTD points to a well defined URI,
* and resolve to our internal DTDs.<p>
*
* If the systemId points to a file, then we attempt to read the
* DTD from the filesystem, in case they've been modified by the user.
* Otherwise, we fallback to the built-in DTDs inside jPOS.<p>
*
* @param publicId The public identifier of the external entity
* being referenced, or null if none was supplied.
* @param systemId The system identifier of the external entity
* being referenced.
* @return An InputSource object describing the new input source,
* or null to request that the parser open a regular
* URI connection to the system identifier.
* @throws org.xml.sax.SAXException Any SAX exception, possibly
* wrapping another exception.
* @throws java.io.IOException A Java-specific IO exception,
* possibly the result of creating a new InputStream
* or Reader for the InputSource.
* @see org.xml.sax.InputSource
*/
public InputSource resolveEntity(String publicId, String systemId) throws SAXException, IOException
{
if(systemId==null) return null;
ClassLoader cl =Thread.currentThread().getContextClassLoader();
cl = cl ==null?ClassLoader.getSystemClassLoader() : cl;
{
final URL resource = cl.getResource("org/jpos/iso/packager/genericpackager.dtd");
return new InputSource(resource.toExternalForm());
}
{
final URL resource = cl.getResource("org/jpos/iso/packager/generic-validating-packager.dtd");
return new InputSource(resource.toExternalForm());
}
URL url=new URL(systemId);
if(url.getProtocol().equals("file"))
{
String file=url.getFile();
if(file.endsWith(".dtd"))
{
File f=new File(file);
InputStream res=null;
if(f.exists())
{
res=new FileInputStream(f);
}
if(res==null)
{
String dtdResource="org/jpos/iso/packager/"+f.getName();
res= cl.getResourceAsStream(dtdResource);
}
if(res!=null) return new InputSource(res);
}
}
return null;
}
}
public class GenericContentHandler extends DefaultHandler
{
private Stack<Object> fieldStack;
@Override
public void startDocument()
{
fieldStack = new Stack<Object>();
}
@Override
public void endDocument() throws SAXException
{
if (!fieldStack.isEmpty())
{
throw new SAXException ("Format error in XML Field Description File");
}
}
@Override
public void startElement(String namespaceURI, String localName, String qName, Attributes atts)
throws SAXException
{
try
{
String id = atts.getValue("id");
String type = atts.getValue("class");
String name = atts.getValue("name");
String size = atts.getValue("length");
String pad = atts.getValue("pad");
// Modified for using IF_TBASE
String token = atts.getValue("token");
if (localName.equals("isopackager"))
{
// Stick a new Map on stack to collect the fields
fieldStack.push(new TreeMap());
setMOROCCOFinalPackagerParams (atts);
}
if (localName.equals("isofieldpackager"))
{
/*
For a isofield packager node push the following fields
onto the stack.
1) an Integer indicating the field ID
2) an instance of the specified ISOFieldPackager class
3) an instance of the specified ISOBasePackager (msgPackager) class
4) a Map to collect the subfields
*/
String packager = atts.getValue("packager");
fieldStack.push(new Integer(id));
ISOFieldPackager f;
f = (ISOFieldPackager) Class.forName(type).newInstance();
f.setDescription(name);
f.setLength(Integer.parseInt(size));
f.setPad(Boolean.parseBoolean(pad));
// Modified for using IF_TBASE
if( f instanceof IF_TBASE){
((IF_TBASE)f).setToken( token );
}
fieldStack.push(f);
ISOBasePackager p;
p = (ISOBasePackager) Class.forName(packager).newInstance();
if (p instanceof MOROCCOFinalPackager)
{
XXXXFInalPackager gp = (XXXXFinalPackager) p;
gp.setXXXXFinalPackagerParams (atts);
}
fieldStack.push(p);
fieldStack.push(new TreeMap());
}
if (localName.equals("isofield"))
{
Class c = Class.forName(type);
ISOFieldPackager f;
f = (ISOFieldPackager) c.newInstance();
f.setDescription(name);
f.setLength(Integer.parseInt(size));
f.setPad(Boolean.parseBoolean(pad));
// Modified for using IF_TBASE
if( f instanceof IF_TBASE){
((IF_TBASE)f).setToken( token );
}
// Insert this new isofield into the Map
// on the top of the stack using the fieldID as the key
Map m = (Map) fieldStack.peek();
m.put(new Integer(id), f);
}
}
catch (Exception ex)
{
throw new SAXException(ex);
}
}
/**
* Convert the ISOFieldPackagers in the Map
* to an array of ISOFieldPackagers
*/
private ISOFieldPackager[] makeFieldArray(Map<Integer,ISOFieldPackager> m)
{
int maxField = 0;
// First find the largest field number in the Map
for (Entry<Integer,ISOFieldPackager> ent :m.entrySet())
if (ent.getKey() > maxField)
maxField = ent.getKey();
// Create the array
ISOFieldPackager fld[] = new ISOFieldPackager[maxField+1];
// Populate it
for (Entry<Integer,ISOFieldPackager> ent :m.entrySet())
fld[ent.getKey()] = ent.getValue();
return fld;
}
@Override
public void endElement(String namespaceURI, String localName, String qName)
{
Map<Integer,ISOFieldPackager> m;
if (localName.equals("isopackager"))
{
m = (Map)fieldStack.pop();
setFieldPackager(makeFieldArray(m));
}
if (localName.equals("isofieldpackager"))
{
// Pop the 4 entries off the stack in the correct order
m = (Map)fieldStack.pop();
ISOBasePackager msgPackager = (ISOBasePackager) fieldStack.pop();
msgPackager.setFieldPackager (makeFieldArray(m));
ISOFieldPackager fieldPackager = (ISOFieldPackager) fieldStack.pop();
Integer fno = (Integer) fieldStack.pop();
msgPackager.setLogger (getLogger(), getRealm() + "-fld-" + fno);
// Create the ISOMsgField packager with the retrieved msg and field Packagers
ISOMsgFieldPackager mfp =
new ISOMsgFieldPackager(fieldPackager, msgPackager);
// Add the newly created ISOMsgField packager to the
// lower level field stack
m=(Map)fieldStack.peek();
m.put(fno, mfp);
}
}
// ErrorHandler Methods
@Override
public void error (SAXParseException ex) throws SAXException
{
throw ex;
}
@Override
public void fatalError (SAXParseException ex) throws SAXException
{
throw ex;
}
}
@Override
protected int getFirstField() {
if (firstField != null)
return Integer.parseInt (firstField);
else return super.getFirstField();
}
/**
* @param m the Container of this message
* @param b ISO message image
* @return consumed bytes
* @exception ISOException
*/
@Override
public int unpack (ISOComponent m, byte[] b) throws ISOException {
LogEvent evt = new LogEvent (this, "unpack");
int consumed = 0;
try {
if (m.getComposite() != m)
throw new ISOException ("Can't call packager on non Composite");
if (logger != null) // save a few CPU cycle if no logger available
evt.addMessage (ISOUtil.hexString (b));
// if ISOMsg and headerLength defined
if (m instanceof ISOMsg /*&& ((ISOMsg) m).getHeader()==null*/ && headerLength>0)
{
byte[] h = new byte[headerLength];
System.arraycopy(b, 0, h, 0, headerLength);
((ISOMsg) m).setHeader(h);
consumed += headerLength;
System.out.println("header = "+ ISOUtil.hexString(h));
}
if (!(fld[0] == null) && !(fld[0] instanceof ISOBitMapPackager) && consumed==15)
{
consumed = consumed-4;
ISOComponent mti = fld[0].createComponent(0);
consumed += fld[0].unpack(mti, b, consumed);
m.set (mti);
}
else if (!(fld[0] == null) && !(fld[0] instanceof ISOBitMapPackager))
{
ISOComponent mti = fld[0].createComponent(0);
consumed += fld[0].unpack(mti, b, consumed);
m.set (mti);
}
BitSet bmap = null;
int maxField = fld.length;
if (emitBitMap()) {
ISOBitMap bitmap = new ISOBitMap (-1);
consumed += getBitMapfieldPackager().unpack(bitmap,b,consumed);
bmap = (BitSet) bitmap.getValue();
if (logger != null)
evt.addMessage ("<bitmap>"+bmap.toString()+"</bitmap>");
m.set (bitmap);
maxField = Math.min(maxField, bmap.size());
}
for (int i=getFirstField(); i<maxField; i++) {
try {
if (bmap == null && fld[i] == null)
continue;
if (maxField > 128 && i==65)
continue; // ignore extended bitmap
if (bmap == null || bmap.get(i)) {
if (fld[i] == null)
throw new ISOException ("field packager '" + i + "' is null");
ISOComponent c = fld[i].createComponent(i);
consumed += fld[i].unpack (c, b, consumed);
if (logger != null) {
evt.addMessage ("<unpack fld=\"" + i
+"\" packager=\""
+fld[i].getClass().getName()+ "\">");
if (c.getValue() instanceof ISOMsg)
evt.addMessage (c.getValue());
else if (c.getValue() instanceof byte[]) {
evt.addMessage (" <value type='binary'>"
+ISOUtil.hexString((byte[]) c.getValue())
+ "</value>");
}
else {
evt.addMessage (" <value>"
+c.getValue()
+ "</value>");
}
evt.addMessage ("</unpack>");
}
m.set(c);
}
} catch (ISOException e) {
evt.addMessage (
"error unpacking field " + i + " consumed=" + consumed
);
evt.addMessage (e);
// jPOS-3
e = new ISOException (
String.format ("%s (%s) unpacking field=%d, consumed=%d",
e.getMessage(), e.getNested().toString(), i, consumed)
);
throw e;
}
}
if (b.length != consumed) {
evt.addMessage (
"WARNING: unpack len=" +b.length +" consumed=" +consumed
);
}
return consumed;
} catch (ISOException e) {
evt.addMessage (e);
throw e;
} catch (Exception e) {
evt.addMessage (e);
throw new ISOException (e.getMessage() + " consumed=" + consumed);
} finally {
Logger.log (evt);
}
}
-------------------------------------------------------------------
asciiB-custom.xml
==============
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<!DOCTYPE isopackager PUBLIC
"-//jPOS/jPOS Generic Packager DTD 1.0//EN"
<!-- ISO 8583:1993 (ASCII) field descriptions for GenericPackager -->
<isopackager headerLength="15">
<isofield
id="0"
length="4"
name="Message Type Indicator"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="1"
length="16"
name="Bitmap"
class="org.jpos.iso.IFB_BITMAP"/>
<isofield
id="2"
length="19"
name="Primary Account number"
class="org.jpos.iso.IFA_LLNUM"/>
<isofield
id="3"
length="6"
name="Processing Code"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="4"
length="12"
name="Amount, Transaction"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="5"
length="12"
name="Amount, Reconciliation"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="6"
length="12"
name="Amount, Cardholder billing"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="7"
length="10"
name="Date and time, transmission"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="8"
length="8"
name="Amount, Cardholder billing fee"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="9"
length="8"
name="Conversion rate, Reconciliation"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="10"
length="8"
name="Conversion rate, Cardholder billing"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="11"
length="6"
name="Systems trace audit number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="12"
length="12"
name="Date and time, Local transaction"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="13"
length="4"
name="Date, Effective"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="14"
length="4"
name="Date, Expiration"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="15"
length="6"
name="Date, Settlement"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="16"
length="4"
name="Date, Conversion"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="17"
length="4"
name="Date, Capture"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="18"
length="4"
name="Merchant type"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="19"
length="3"
name="Country code, Acquiring institution"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="20"
length="3"
name="Country code, Primary account number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="21"
length="3"
name="Country code, Forwarding institution"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="22"
length="12"
name="Point of service data code"
class="org.jpos.iso.IF_CHAR"/>
<isofield
id="23"
length="3"
name="Card sequence number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="24"
length="3"
name="Function code"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="25"
length="4"
name="Message reason code"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="26"
length="4"
name="Card acceptor business code"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="27"
length="1"
name="Approval code length"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="28"
length="6"
name="Date, Reconciliation"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="29"
length="3"
name="Reconciliation indicator"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="30"
length="24"
name="Amounts, original"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="31"
length="99"
name="Acquirer reference data"
class="org.jpos.iso.IFA_LLCHAR"/>
<isofield
id="32"
length="11"
name="Acquirer institution identification code"
class="org.jpos.iso.IFA_LLNUM"/>
<isofield
id="33"
length="11"
name="Forwarding institution identification code"
class="org.jpos.iso.IFA_LLNUM"/>
<isofield
id="34"
length="28"
name="Primary account number, extended"
class="org.jpos.iso.IFA_LLCHAR"/>
<isofield
id="35"
length="37"
name="Track 2 data"
class="org.jpos.iso.IFA_LLCHAR"/>
<isofield
id="36"
length="104"
name="Track 3 data"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="37"
length="12"
name="Retrieval reference number"
class="org.jpos.iso.IF_CHAR"/>
<isofield
id="38"
length="6"
name="Approval code"
class="org.jpos.iso.IF_CHAR"/>
<isofield
id="39"
length="3"
name="Action code"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="40"
length="3"
name="Service code"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="41"
length="16"
name="Card acceptor terminal identification"
class="org.jpos.iso.IF_CHAR"/>
<isofield
id="42"
length="15"
name="Card acceptor identification code"
class="org.jpos.iso.IF_CHAR"/>
<isofield
id="43"
length="99"
name="Card acceptor name/location"
class="org.jpos.iso.IFA_LLCHAR"/>
<isofield
id="44"
length="99"
name="Additional Response data"
class="org.jpos.iso.IFA_LLCHAR"/>
<isofield
id="45"
length="76"
name="Track 1 data"
class="org.jpos.iso.IFA_LLCHAR"/>
<isofield
id="46"
length="204"
name="Amounts, Fees"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="47"
length="999"
name="Additional data - national"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="48"
length="999"
name="Additional data - private"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="49"
length="3"
name="Currency code, Transaction"
class="org.jpos.iso.IF_CHAR"/>
<isofield
id="50"
length="3"
name="Currency code, Reconciliation"
class="org.jpos.iso.IF_CHAR"/>
<isofield
id="51"
length="3"
name="Currency code, Cardholder billing"
class="org.jpos.iso.IF_CHAR"/>
<isofield
id="52"
length="8"
name="Personal identification number [PIN] data"
class="org.jpos.iso.IFA_BINARY"/>
<isofield
id="53"
length="48"
name="Security related control information"
class="org.jpos.iso.IFA_LLBINARY"/>
<isofield
id="54"
length="120"
name="Amounts, additional"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="55"
length="255"
name="IC card system related data"
class="org.jpos.iso.IFA_LLLBINARY"/>
<isofield
id="56"
length="35"
name="Original data elements"
class="org.jpos.iso.IFA_LLNUM"/>
<isofield
id="57"
length="3"
name="Authorization lIFA cycle code"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="58"
length="11"
name="Authorizing agent institution Id Code"
class="org.jpos.iso.IFA_LLNUM"/>
<isofield
id="59"
length="999"
name="Transport data"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="60"
length="999"
name="Reserved for national use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="61"
length="999"
name="Reserved for national use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="62"
length="999"
name="Reserved for private use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="63"
length="999"
name="Reserved for private use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="64"
length="8"
name="Message authentication code field"
class="org.jpos.iso.IF_CHAR"/>
<isofield
id="65"
length="8"
name="Reserved for ISO use"
class="org.jpos.iso.IFA_BINARY"/>
<isofield
id="66"
length="204"
name="Amounts, original fees"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="67"
length="2"
name="Extended payment data"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="68"
length="3"
name="Country code, receiving institution"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="69"
length="3"
name="Country code, settlement institution"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="70"
length="3"
name="Country code, authorizing agent Inst."
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="71"
length="8"
name="Message number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="72"
length="999"
name="Data record"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="73"
length="6"
name="Date, action"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="74"
length="10"
name="Credits, number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="75"
length="10"
name="Credits, reversal number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="76"
length="10"
name="Debits, number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="77"
length="10"
name="Debits, reversal number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="78"
length="10"
name="Transfer, number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="79"
length="10"
name="Transfer, reversal number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="80"
length="10"
name="Inquiries, number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="81"
length="10"
name="Authorizations, number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="82"
length="10"
name="Inquiries, reversal number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="83"
length="10"
name="Payments, number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="84"
length="10"
name="Payments, reversal number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="85"
length="10"
name="Fee collections, number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="86"
length="16"
name="Credits, amount"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="87"
length="16"
name="Credits, reversal amount"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="88"
length="16"
name="Debits, amount"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="89"
length="16"
name="Debits, reversal amount"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="90"
length="10"
name="Authorizations, reversal number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="91"
length="3"
name="Country code, transaction Dest. Inst."
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="92"
length="3"
name="Country code, transaction Orig. Inst."
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="93"
length="11"
name="Transaction Dest. Inst. Id code"
class="org.jpos.iso.IFA_LLNUM"/>
<isofield
id="94"
length="11"
name="Transaction Orig. Inst. Id code"
class="org.jpos.iso.IFA_LLNUM"/>
<isofield
id="95"
length="99"
name="Card issuer reference data"
class="org.jpos.iso.IFA_LLCHAR"/>
<isofield
id="96"
length="999"
name="Key management data"
class="org.jpos.iso.IFA_LLLBINARY"/>
<isofield
id="97"
length="17"
name="Amount, Net reconciliation"
class="org.jpos.iso.IFA_AMOUNT"/>
<isofield
id="98"
length="25"
name="Payee"
class="org.jpos.iso.IF_CHAR"/>
<isofield
id="99"
length="11"
name="Settlement institution Id code"
class="org.jpos.iso.IFA_LLCHAR"/>
<isofield
id="100"
length="11"
name="Receiving institution Id code"
class="org.jpos.iso.IFA_LLNUM"/>
<isofield
id="101"
length="17"
name="File name"
class="org.jpos.iso.IFA_LLCHAR"/>
<isofield
id="102"
length="28"
name="Account identification 1"
class="org.jpos.iso.IFA_LLCHAR"/>
<isofield
id="103"
length="28"
name="Account identification 2"
class="org.jpos.iso.IFA_LLCHAR"/>
<isofield
id="104"
length="100"
name="Transaction description"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="105"
length="16"
name="Credits, Chargeback amount"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="106"
length="16"
name="Debits, Chargeback amount"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="107"
length="10"
name="Credits, Chargeback number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="108"
length="10"
name="Debits, Chargeback number"
class="org.jpos.iso.IFA_NUMERIC"/>
<isofield
id="109"
length="84"
name="Credits, Fee amounts"
class="org.jpos.iso.IFA_LLCHAR"/>
<isofield
id="110"
length="84"
name="Debits, Fee amounts"
class="org.jpos.iso.IFA_LLCHAR"/>
<isofield
id="111"
length="999"
name="Reserved for ISO use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="112"
length="999"
name="Reserved for ISO use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="113"
length="999"
name="Reserved for ISO use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="114"
length="999"
name="Reserved for ISO use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="115"
length="999"
name="Reserved for ISO use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="116"
length="999"
name="Reserved for national use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="117"
length="999"
name="Reserved for national use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="118"
length="999"
name="Reserved for national use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="119"
length="999"
name="Reserved for national use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="120"
length="999"
name="Reserved for national use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="121"
length="999"
name="Reserved for national use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="122"
length="999"
name="Reserved for national use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="123"
length="999"
name="Reserved for private use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="124"
length="999"
name="Reserved for private use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="125"
length="999"
name="Reserved for private use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="126"
length="999"
name="Reserved for private use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="127"
length="999"
name="Reserved for private use"
class="org.jpos.iso.IFA_LLLCHAR"/>
<isofield
id="128"
length="8"
name="Message authentication code field"
class="org.jpos.iso.IF_CHAR"/>
</isopackager>
------------------------------------------------------------------------------------------------------------------------------------------------------------
XXXXChannel.java code
=====================
package com.xx.xxxxx;
import java.io.EOFException;
import java.io.IOException;
import java.io.InterruptedIOException;
import java.net.Socket;
import org.jpos.iso.ISOException;
import org.jpos.iso.ISOMsg;
import org.jpos.iso.ISOPackager;
import org.jpos.iso.channel.ASCIIChannel;
import org.jpos.iso.ISOUtil;
import java.io.*;
import java.net.*;
import java.util.ArrayList;
import javax.net.ssl.SSLSocket;
import org.jpos.iso.ISOUtil;
import org.jpos.q2.Q2;
import org.jpos.util.LogEvent;
import org.jpos.util.LogSource;
import org.jpos.util.Logger;
import org.jpos.util.Log;
import org.jpos.iso.ISOException;
import org.jpos.util.SimpleLogListener;
public class XXXXXChannel extends ASCIIChannel {
private Log log;
private static Log logStatic;
final protected static char[] hexArray = "0123456789ABCDEF".toCharArray();
private ByteArrayOutputStream baos = new ByteArrayOutputStream();
DataInputStream ds = null;
int msgLngth = 0;
StringBuffer inputLine = new StringBuffer();
int tmp=0;
private boolean expectKeepAlive;
private Socket socket;
private boolean soLingerOn = true;
private int soLingerSeconds = 5;
XXXXPackager packager;
public XXXXXChannel(){
log = Log.getLog(Q2.LOGGER_NAME, "XXXXXChannel");
}
public XXXXXChannel(XXXXPackager packager) throws ISOException {
packager = new XXXXPackager("asciiB-custom.xml");
this.packager = packager;
}
@Override
protected int getMessageLength() throws IOException, ISOException {
int length = 0;
byte[] b = new byte[4];
log.info ("Inside XXXXXChannel.getMessageLength() line # 62--> ");
while (length == 0) {
serverIn.readFully(b, 0, 4);
log.info ("Inside XXXXXChannel.getMessageLength() line # 65--> " + length);
try {
if ((length = Integer.parseInt(new String(b))) == 0) {
serverOut.write(b);
serverOut.flush();
log.info ("Inside XXXXXChannel.getMessageLength() line # 70--> " + length);
}
} catch (NumberFormatException e) {
throw new ISOException("Invalid message length " + new String(b));
}
}
log.info ("Inside XXXXXChannel.getMessageLength() line # 76 --> " + length);
return length;
}
private String convertHexToString(String hexString){
StringBuilder sb = new StringBuilder(hexString.length() / 2);
for (int i = 0; i < hexString.length(); i+=2) {
String hex = "" + hexString.charAt(i) + hexString.charAt(i+1);
int ival = Integer.parseInt(hex, 16);
sb.append((char) ival);
}
return sb.toString();
}
@Override
protected int getHeaderLength() {
log.info ("Inside XXXXXChannel.getHeaderLength() line # 82--> ");
return 15;
}
@Override
public ISOMsg receive() throws IOException, ISOException {
byte[] b=null;
byte[] header=null;
LogEvent evt = new LogEvent (this, "receive");
ISOMsg m = createMsg (); // call createMsg instead of createISOMsg for
// backward compatibility
m.setSource (this);
try {
if (!isConnected())
throw new ISOException ("unconnected ISOChannel");
log.info ("Inside XXXXXChannel.receive() line # 125--> ");
synchronized (serverInLock) {
int len = getMessageLength();
int hLen = getHeaderLength();
if (len == -1) {
if (hLen > 0) {
header = readHeader(hLen);
log.info ("Inside XXXXXChannel.receive() line # 144--> " +header.length);
}
b = streamReceive();
}
else if (len > 0 && len <= getMaxPacketLength()) {
if (hLen > 0) {
// ignore message header (TPDU)
// Note header length is not necessarily equal to hLen (see VAPChannel)
header = readHeader(hLen);
log.info ("Inside XXXXXChannel.receive() line # 144--> " +header.length);
len -= header.length;
}
b = new byte[len];
log.info ("Inside XXXXXChannel.receive() line # 144--> " +len);
getMessage (b, 0, len);
getMessageTrailler();
}
else
throw new ISOException(
"receive length " +len + " seems strange - maxPacketLength = " + getMaxPacketLength());
}
// m.setPackager (getDynamicPackager(header, b));
m.setHeader (getDynamicHeader(header));
Logger l = new Logger();
l.addListener(new SimpleLogListener());
XXXXFinalPackager pkgr = new XXXXFinalPackager("asciiB-custom.xml");
pkgr.setLogger(l,"");
// if (b.length > 0 && !shouldIgnore (header)) // Ignore NULL messages
//pkgr.unpackResp (m, b);
pkgr.unpack (m, b);
m.setDirection(ISOMsg.INCOMING);
evt.addMessage (m);
m = applyIncomingFilters (m, header, b, evt);
m.setDirection(ISOMsg.INCOMING);
cnt[RX]++;
setChanged();
notifyObservers(m);
} catch (ISOException e) {
evt.addMessage (e);
if (header != null) {
evt.addMessage ("--- header ---");
evt.addMessage (ISOUtil.hexdump (header));
}
if (b != null) {
evt.addMessage ("--- data ---");
evt.addMessage (ISOUtil.hexdump (b));
}
throw e;
} catch (EOFException e) {
closeSocket();
evt.addMessage ("<peer-disconnect/>");
throw e;
} catch (SocketException e) {
closeSocket();
if (usable)
evt.addMessage ("<peer-disconnect>" + e.getMessage() + "</peer-disconnect>");
throw e;
} catch (InterruptedIOException e) {
closeSocket();
evt.addMessage ("<io-timeout/>");
throw e;
} catch (IOException e) {
closeSocket();
if (usable)
evt.addMessage (e);
throw e;
} catch (Exception e) {
evt.addMessage (m);
evt.addMessage (e);
throw new ISOException ("unexpected exception", e);
} finally {
Logger.log (evt);
}
return m;
}
@Override
protected void getMessage(byte[] b, int offset, int len) throws IOException, ISOException {
try{
if((serverIn.available())!=-1){
log.info("XXXXXChannel.getMessage() line# 203--> " +len);
//serverIn.readFully(b, offset, len);
serverIn.readFully(b);
log.info("XXXXXChannel.getMessage() line# 205--> ",b.length);
}
}catch(EOFException e){
log.error("Exception in XXXXXChannel.getMessage() line# 209--> ", e);
}
/*for ( int j = 0; j < b.length; j++ ) {
int v = b[j] & 0xFF;
log.info ("Inside XXXXXChannel.getMessage() line# 188--> " + v );
}*/
}
@Override
protected void sendMessageHeader(ISOMsg m, int len) throws IOException {
}
public String bytesToHex(byte[] bytes) {
char[] hexChars = new char[bytes.length * 2];
for ( int j = 0; j < bytes.length; j++ ) {
int v = bytes[j] & 0xFF;
log.info ("Inside XXXXXChannel.bytesToHex() line# 290--> " + v);
hexChars[j * 2] = hexArray[v >>> 4];
hexChars[j * 2 + 1] = hexArray[v & 0x0F];
}
return new String(hexChars);
}
public String bitwiseShiftHexValue(String hexStringBefore){
String hexStringAfter = null;
StringBuffer sBuff = new StringBuffer();
for(int i=0; i<32;){
hexStringAfter = hexStringBefore.substring(i+6, i+8);
sBuff = sBuff.append(hexStringAfter);
i=i+8;
}
return sBuff.toString();
}
public String hexToAscii(String hexString){
StringBuilder output = new StringBuilder();
for (int i = 0; i < hexString.length(); i+=2) {
String str = hexString.substring(i, i+2);
output.append((char)Integer.parseInt(str, 16));
}
return output.toString();
}
@Override
protected ISOPackager getDynamicPackager(byte[] b1, byte[] b2) {
try{
log.info ("Inside XXXXXChannel.getDynamicPackager() line #322--> ");
return new XXXXPackager("asciiB-custom.xml");
}catch (ISOException e){
log.error("Inside XXXXXChannel.getDynamicPackager() line #325 --> ", e);
}
return null;
}
protected byte[] readHeader(int hLen)
throws IOException
{
byte[] header = new byte[hLen];
serverIn.readFully(header, 0, hLen);
return header;
}
private void closeSocket() throws IOException {
Socket s = null;
synchronized (this) {
if (socket != null) {
s = socket;
socket = null;
}
}
if (s != null) {
try {
s.setSoLinger(soLingerOn, soLingerSeconds);
if ((shutdownSupportedBySocket(s)) && (!isSoLingerForcingImmediateTcpReset())) {
s.shutdownOutput();
}
}
catch (SocketException e) {}
s.close();
}
}
private boolean shutdownSupportedBySocket(Socket s) { return !(s instanceof SSLSocket); }
private boolean isSoLingerForcingImmediateTcpReset() { return (soLingerOn) && (soLingerSeconds == 0); }
}
