Today i want to share about Implementation JPos Transaction Manager. In this post, i will implement the integration with ISORequestListener, Transaction Manager Group Selector, Transaction Participant, and Abort Participant.

From JPos Programmer guide book, the explanation of TransactionManager is:

The TransactionManager implementation takes care of ‘driving’ the transaction by calling all of the participants’ prepare methods. If all of them return ‘PREPARED’, then the transaction moves to the committing phase, at which point the TransactionManager will call all of the participants’ commit methods.
If one of the participants’ prepare methods were to return ABORTED, then the transaction would move into an aborting phase, and all the participants’ abort methods would get called.

In this post, we will implement GroupSelector interface for choose the transaction group. GroupSelector is used to simplify the TransactionManager.

A participant implementing the GroupSelector interface can modify the flow of this transaction by returning a space-separated list of group names (or can specify ‘null’ to signify no action).

you can read the JPos Programmer Guide for more explanation about TransactionManager. You can purchase here.

As always, we have to create some xml file on deploy folder.

• 00_logger.xml
• 10_server.xml
• 20_transaction_manager.xml
• 30_clientsimulator_channel.xml
• 40_clientsimulator_mux.xml
• 50_jposclient_channel_manager.xml
• 99_sysmon.xml

There are channel, mux, and channel manager in this tutorial, because we will get some data from another server. The Flow service is shown on picture below:

First of all, we have to create 10_server.xml file.
[xml]

12260
100
0

[/xml]
This server will listen on port 12260, using NACChannel with CustomPackager, and the request will be listened on JPosServerListener class.

Then, the JPosServerListener is look like:
[java]
public class JPosServerListener implements ISORequestListener, Configurable {

private String queueName;
private Space sp;
private Long timeout;

public JPosServerListener() {
super();
}

public static void main(String[] args) {
Q2 q2 = new Q2();
q2.start();
}

@Override
public boolean process(ISOSource isoSrc, ISOMsg isoMsg) {
Context ctx = new Context();
ctx.put(Constant.REQUEST, isoMsg);
ctx.put(Constant.ISOSOURCE, isoSrc);
sp.out(queueName, ctx, timeout);
return true;
}

@SuppressWarnings(“unchecked”)
@Override
public void setConfiguration(Configuration cfg)
throws ConfigurationException {
queueName = cfg.get(“queue”);
timeout = cfg.getLong(“timeout”);
sp = SpaceFactory.getSpace(cfg.get(“space”));
}

}
[/java]

In process method, we will create new context then put the request message, and requester (IsoSource) to the context, then put the context to the space, so TransactionManager will process the request.

Then, after creating the server, we have to configure the TransactionManager. The 20_transaction_manager.xml look like:
[xml]

[/xml]
By using GroupSelector, we have to class that implement GroupSelector interface. In this tutorial, i create Switch class and will override the select class of GroupSelector interface.
[java]
/**
* GroupSelector implementation class
* @author Didik Hari
* @since 02-Feb-2015
*/
public class Switch implements GroupSelector, Configurable {
private Configuration cfg;

@Override
public void abort(long id, Serializable context) { }

@Override
public void commit(long id, Serializable context) { }

@Override
public int prepare(long id, Serializable context) {
return PREPARED | READONLY | NO_JOIN;
}

@Override
public String select(long id, Serializable context) {
try {
ISOMsg reqMsg = (ISOMsg) ((Context)context).get(Constant.REQUEST);
return cfg.get(reqMsg.getMTI(), null);
} catch (Exception e) {
return null;
}
}

@Override
public void setConfiguration(Configuration cfg)
throws ConfigurationException {
this.cfg = cfg;
}

}
[/java]

if the select method return 0800, JPos will invoke NetworkManagement group, and if return 0200 FinancialTransaction group will be invoked.

And finally we have to implement the transactionParticipant for the implementation of group participant.
The first participant we create is message validator class. This class will overade method prepare and abort. the abort method will send response to the requester (isoSource) with response code ’01’ or general error. And the prepare methods will validate the bit124, if bit 124 not valid, transactionManager will abort the transaction, and send response to the client using abort method.
[java]
/**
* Validate the request message
* if bit 124 is null or filled with space or empty string, then abort the transaction
* abort method will send response with response code ’01’ (General Error)
*
* @author Didik Hari
*
*/
public class FinancialTransactionValidateMessage implements TransactionParticipant {