jPOS Client Receive Response to Specific Port

[java]
public class ChannelManager extends QBeanSupport {
private long MAX_TIME_OUT;
private MUX mux;

@Override
protected void initService() throws ISOException {
log.info(“initializing ChannelManager Service”);
try {
mux = (MUX) NameRegistrar.get(“mux.” + cfg.get(“mux”));
MAX_TIME_OUT = cfg.getLong(“timeout”);
NameRegistrar.register(“manager”, this);
} catch (NameRegistrar.NotFoundException e) {
log.error(“Error in initializing service :” + e.getMessage());
}

}

public ISOMsg sendMsg(ISOMsg m) throws Exception {
return sendMsg(m, mux, MAX_TIME_OUT);
}

@SuppressWarnings({“unchecked” })
private ISOMsg sendMsg(ISOMsg msg, MUX mux, long time) throws Exception {

if (mux != null) {
long start = System.currentTimeMillis();
mux.request(msg, 1);
String msgId = msg.getString(11);
Space space = SpaceFactory.getSpace(“tspace:mySpace”);
ISOMsg responseInSpace = space.in(msgId, 10000L);
long duration = System.currentTimeMillis() – start;
log.info(“Response time (ms):” + duration);
return responseInSpace;
}
return null;
}
}
[/java]

space.in(msgId, 10000L) will Wait a maximum of 10000 milliseconds for a given entry; otherwise, return null.

Before we create the requester class, we need to prepare jPOS QServer for listen the response and put to the Space

[xml]

12261
50
10

[/xml]

[java]
public class ResponseListener implements ISORequestListener, Configurable {

private Space sp;

@Override
public boolean process(ISOSource source, ISOMsg msg) {
sp.out(msg.getString(11), msg);
return true;
}

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

}
[/java]

sp.out(msg.getString(11), msg) will put the response message to the space and give it key with bit 11 from the message.

and the last thing we have to do is create the requester class

[java]
public class JPosClient {

static void start() {
Q2 q2 = new Q2();
q2.start();
}

public static void main(String[] args) throws ISOException {
start();
ISOUtil.sleep(2000);
new Thread(new Exec()).start();
}

static class Exec implements Runnable {

ChannelManager channelManager;

Exec() throws ISOException {
try {
channelManager = ((ChannelManager) NameRegistrar.get(“manager”));
} catch (NameRegistrar.NotFoundException e) {
LogEvent evt = channelManager.getLog().createError();
evt.addMessage(e);
evt.addMessage(NameRegistrar.getInstance());
Logger.log(evt);
} catch (Throwable t) {
channelManager.getLog().error(t);
}

}

private ISOMsg createHandshakeISOMsg() throws ISOException {
ISOMsg m = new ISOMsg();
m.setHeader(“ISO006000050”.getBytes());
m.setMTI(“0800”);
m.set(7, ISODate.getDateTime(new Date()));
m.set(11, String.valueOf(System.currentTimeMillis() % 1000000));
m.set(32, “00001603307”);
m.set(41, “T1603307”);
m.set(70, “301”);
return m;
}

private void sendHandShake() throws Exception {
try {
ISOMsg response = channelManager.sendMsg(createHandshakeISOMsg());
channelManager.getLog().info(new String(response.pack()));
} catch (ISOException e1) {
channelManager.getLog().error(
“ISOException :” + e1.getMessage());
} catch (Exception e) {
channelManager.getLog().error(“Exception :” + e.getMessage());
}

}

@Override
public void run() {
while (true) {
// ISOUtil.sleep(2000);
try {
sendHandShake();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
}
[/java]

it’s All post about jPOS Client Receive Response to Specific Port, hope this post can help you. please leave comment below.