使用MUX为所有传入请求创建另一个定制的打包程序我的外发请求没有问题

如何解决使用MUX为所有传入请求创建另一个定制的打包程序我的外发请求没有问题

我有一个jpos实现,可以发送和接收iso消息。首先需要先登录。 作为客户端,我能够发送请求(customized.xml打包程序),也可以成功接收响应,而不会出现任何问题。

但是,当另一方向我发送请求时,同一打包程序(customized.xml打包程序)无法解包收到的请求。

为了尝试解决传入请求的问题,我决定创建一个新的自定义打包程序(customized2.xml),但是我注意到所有传入请求仍在引用旧的打包程序(customized.xml)。 我该如何处理呢?或者最好的做法是什么。

我的配置:

10_mychannel.xml

    <?xml version="1.0" encoding="UTF-8"?>
    <channel-adaptor name="mychannel-channel" logger="Q2">
       <channel class="org.jpos.iso.channel.ASCIIChannel" type="client" connect="yes" logger="Q2" realm="post-channel" packager="org.jpos.iso.packager.GenericPackager">
          <property name="packager-config" value="cfg/customized.xml" />
          <property name="packager-logger" value="Q2" />
          <property name="packager-realm" value="custom-packager" />
          <property name="host" value="14.101.333.111" />
          <property name="port" value="7777" />
          <property name="length-digits" value="6" />
          <property name="connection-timeout" value="30000" />
          <property name="timeout" value="300000" />
       </channel>
       <in>my-channel-send</in>
      <out>my-channel-receive</out>
       <reconnect-delay>10000</reconnect-delay>
       <keep-alive>yes</keep-alive>
    </channel-adaptor>

20_my_mux.xml

    <mux class="org.jpos.q2.iso.QMUX" logger="Q2" name="my-mux">
    <in>my-channel-receive</in>
    <out>my-channel-send</out>
    <ready>my-channel.ready</ready>
    </mux>

21_my_q_beans.xml

    <qbean name='logonManager' class='com.my.processor.logonManager' />

50_my_server.xml

    <server class="org.jpos.q2.iso.QServer" logger="Q2" name="xml-server-7777" realm="xml-server-7777">
      <attr name="port" type="java.lang.Integer">7777</attr>
      <channel class="org.jpos.iso.channel.ASCIIChannel" packager="org.jpos.iso.packager.GenericPackager" type="server" logger="Q2" realm="xml-server-7777">
      <property name="packager-config" value="cfg/customized2.xml" />
      <property name="timeout" value="180000"/>
      </channel>
      <request-listener class="com.my.processor.myListener" logger="Q2" realm="incoming-request-listener" />
    </server>

进样请求

    public class myListener implements ISORequestListener{

        private static final String FTREQUEST = "1200";
        private static final String REVADVICE = "1420";
        private static final String NETWORKREQ = "1804";

        Log log1;

        @Override
        public boolean process(ISOSource source,ISOMsg m) {
            System.out.println("::::: Waiting :::::");
            log.info("::::: Inside  Listener :::::");
            try {
                String mti = m.getMTI();
                System.out.println("mti ::: " + mti);
                log.info("mti ::: " + mti);
                switch (mti) {
                    case FTREQUEST:
                        log.info("Inside Financial Transaction Request");
                        //implementation here 

                        m.setMTI("1210");
                        m.set(2,m.getString(2));
                        m.set(3,m.getString(3));
                        m.set(4,m.getString(4));
                        m.set(11,m.getString(11));
                        m.set(12,m.getString(12));
                        m.set(39,"100");
                        source.send(m);

                        break;
                    case REVADVICE:
                        log.info("Reversal Advice");
                        break;
                    case NETWORKREQ:
                        log.info("Network Management Request");
                        break;
                }

            } catch (Exception ex) {
                ex.printstacktrace(System.out);
            }
            return true;
        }
    }

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其他元素将获得点击?
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。)
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbcDriver发生异常。为什么?
这是用Java进行XML解析的最佳库。
Java的PriorityQueue的内置迭代器不会以任何特定顺序遍历数据结构。为什么?
如何在Java中聆听按键时移动图像。
Java“Program to an interface”。这是什么意思?
Java在半透明框架/面板/组件上重新绘画。
Java“ Class.forName()”和“ Class.forName()。newInstance()”之间有什么区别?
在此环境中不提供编译器。也许是在JRE而不是JDK上运行?
Java用相同的方法在一个类中实现两个接口。哪种接口方法被覆盖?
Java 什么是Runtime.getRuntime()。totalMemory()和freeMemory()?
java.library.path中的java.lang.UnsatisfiedLinkError否*****。dll
JavaFX“位置是必需的。” 即使在同一包装中
Java 导入两个具有相同名称的类。怎么处理?
Java 是否应该在HttpServletResponse.getOutputStream()/。getWriter()上调用.close()?
Java RegEx元字符(。)和普通点?