java - quickfix/field/HaltReason 不可分配给 'quickfix/IntField

Question

当我登录时，我正在发送一个应用程序消息请求 (BW) 并且服务器响应多种类型的消息，但是对于安全状态消息，它返回暂停原因异常。我有 2 个 onMessage 函数，这些用于安全定义报告和安全定义更新报告。安全状态没有 onMessage 功能，因为我没有使用此消息，所以我不希望处理其他类型的消息。当收到安全状态消息时，我们会收到 HaltReason 异常。在这一切之后，我们的客户端无法从服务器接收到任何心跳，因此我们的客户端正在断开连接并发送另一个登录请求。它会导致一个循环，我们会收到消息，与 Halt 原因异常断开连接并再次请求。我们将 FIX50SP2 与 FIXT1.1 一起使用，但 MessageCracker 将这些消息映射到 FIX50。我们还使用 quickfix 2.3.1 版本和 DefaultMessageFactory 来接收 FIX 消息。

例子:

事件>(收到登录)

传入> (8=FIXT.1.1 9=00000 35=f 49=foo 56=foo 34=0000 57=0000 52=20220302-10:11:09.908 1180=R 1181=0000 1350=0000 55=foo 48=0000 22=M 336=135 325=N 60=20220302-10:11:09.908 10=119)

错误>(java.lang.VerifyError:操作数堆栈上的错误类型异常详细信息:地点:quickfix/fix50/SecurityStatus.get(Lquickfix/field/HaltReason;)Lquickfix/field/HaltReason; @2:调用虚拟原因:类型“quickfix/field/HaltReason”(当前帧，堆栈 [1])不可分配给“quickfix/IntField”当前帧:bci: @2标志:{}本地人:{ 'quickfix/fix50/SecurityStatus', 'quickfix/field/HaltReason' }堆栈:{ 'quickfix/fix50/SecurityStatus', 'quickfix/field/HaltReason' }字节码:0x0000000: 2a2b b600 2457 2bb0

java.lang.VerifyError: 操作数栈上的错误类型异常详细信息:地点:quickfix/fix50/SecurityStatus.get(Lquickfix/field/HaltReason;)Lquickfix/field/HaltReason; @2:调用虚拟原因:类型“quickfix/field/HaltReason”(当前帧，堆栈 [1])不可分配给“quickfix/IntField”当前帧:bci: @2标志:{}本地人:{ 'quickfix/fix50/SecurityStatus', 'quickfix/field/HaltReason' }堆栈:{ 'quickfix/fix50/SecurityStatus', 'quickfix/field/HaltReason' }字节码:0x0000000: 2a2b b600 2457 2bb0

at quickfix.fix50.MessageFactory.create(MessageFactory.java:120)
at quickfix.DefaultMessageFactory.create(DefaultMessageFactory.java:141)
at quickfix.MessageUtils.parse(MessageUtils.java:145)
at quickfix.mina.AbstractIoHandler.messageReceived(AbstractIoHandler.java:131)
at org.apache.mina.core.filterchain.DefaultIoFilterChain$TailFilter.messageReceived(DefaultIoFilterChain.java:858)
at org.apache.mina.core.filterchain.DefaultIoFilterChain.callNextMessageReceived(DefaultIoFilterChain.java:542)
at org.apache.mina.core.filterchain.DefaultIoFilterChain.access$1300(DefaultIoFilterChain.java:48)
at org.apache.mina.core.filterchain.DefaultIoFilterChain$EntryImpl$1.messageReceived(DefaultIoFilterChain.java:947)
at org.apache.mina.filter.codec.ProtocolCodecFilter$ProtocolDecoderOutputImpl.flush(ProtocolCodecFilter.java:398)
at org.apache.mina.filter.codec.ProtocolCodecFilter.messageReceived(ProtocolCodecFilter.java:234)
at org.apache.mina.core.filterchain.DefaultIoFilterChain.callNextMessageReceived(DefaultIoFilterChain.java:542)
at org.apache.mina.core.filterchain.DefaultIoFilterChain.access$1300(DefaultIoFilterChain.java:48)
at org.apache.mina.core.filterchain.DefaultIoFilterChain$EntryImpl$1.messageReceived(DefaultIoFilterChain.java:947)
at org.apache.mina.core.filterchain.IoFilterAdapter.messageReceived(IoFilterAdapter.java:109)
at org.apache.mina.core.filterchain.DefaultIoFilterChain.callNextMessageReceived(DefaultIoFilterChain.java:542)
at org.apache.mina.core.filterchain.DefaultIoFilterChain.fireMessageReceived(DefaultIoFilterChain.java:535)
at org.apache.mina.core.polling.AbstractPollingIoProcessor.read(AbstractPollingIoProcessor.java:703)
at org.apache.mina.core.polling.AbstractPollingIoProcessor.process(AbstractPollingIoProcessor.java:659)
at org.apache.mina.core.polling.AbstractPollingIoProcessor.process(AbstractPollingIoProcessor.java:648)
at org.apache.mina.core.polling.AbstractPollingIoProcessor.access$600(AbstractPollingIoProcessor.java:68)
at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:1120)
at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)

)

pom.xml :

<dependency>
            <groupId>org.quickfixj</groupId>
            <artifactId>quickfixj-core</artifactId>
            <version>2.3.1</version>
        </dependency>
        <dependency>
            <groupId>org.quickfixj</groupId>
            <artifactId>quickfixj-messages-fix40</artifactId>
            <version>2.0.0</version>
        </dependency>
        <dependency>
            <groupId>org.quickfixj</groupId>
            <artifactId>quickfixj-messages-fix41</artifactId>
            <version>2.0.0</version>
        </dependency>
        <dependency>
            <groupId>org.quickfixj</groupId>
            <artifactId>quickfixj-messages-fix42</artifactId>
            <version>2.0.0</version>
        </dependency>
        <dependency>
            <groupId>org.quickfixj</groupId>
            <artifactId>quickfixj-messages-fix43</artifactId>
            <version>2.0.0</version>
        </dependency>
        <dependency>
            <groupId>org.quickfixj</groupId>
            <artifactId>quickfixj-messages-fix44</artifactId>
            <version>2.0.0</version>
        </dependency>
        <dependency>
            <groupId>org.quickfixj</groupId>
            <artifactId>quickfixj-messages-fix50</artifactId>
            <version>2.3.1</version>
        </dependency>

FIXApplication50.java:

import org.apache.log4j.Logger;
import quickfix.Message;
import quickfix.MessageCracker;
import quickfix.*;
import quickfix.field.*;
import quickfix.fix50.*;

import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;

public class FIXApplication50 extends MessageCracker implements Application {

    public FIXApplication50() throws ConfigError {
    }

    public void onMessage(SecurityDefinition refData, SessionID sessionID) {
        
    }

    public void onMessage(SecurityDefinitionUpdateReport refData, SessionID sessionID) {

    }

    public void onCreate(SessionID sessionID) {

    }

    public void sendApplicationMessageRequest(Message message, SessionID sessionID) {

    }

    public void onLogon(SessionID sessionID) {
        Message message = new Message();

        sendApplicationMessageRequest(message, sessionID);
    }

    public void onLogout(SessionID sessionID) {

    }


    public void toAdmin(Message message, SessionID sessionID) {
      
    }


    public void fromAdmin(Message message, SessionID sessionID) throws FieldNotFound, IncorrectDataFormat, IncorrectTagValue, RejectLogon {

    }


    public void toApp(Message message, SessionID sessionID) throws DoNotSend {

    }

    public void fromApp(Message message, SessionID sessionId)
            throws FieldNotFound, IncorrectDataFormat, IncorrectTagValue, UnsupportedMessageType {
        crack(message, sessionId);
    }
}

session .properties :

[DEFAULT]
ConnectionType=initiator
ReconnectInterval=60
ResetOnLogon=Y
FileLogPath=logs/plugins/foo/Client_Logs
SenderCompID=foo
SenderSubID=foo
ValidateIncomingMessage=N

[SESSION]
BeginString=FIXT.1.1
TargetCompID=foo
StartDay=sunday
EndDay=friday
StartTime=21:35:00
EndTime=21:30:00
HeartBtInt=30
CheckLatency=N
SocketConnectPort=0000
SocketConnectHost=00.00.00
DefaultApplVerID=FIX.5.0SP2
TransportDataDictionary=config/plugins/foo/FIXT11.xml
AppDataDictionary=config/plugins/foo/RefDataFIX50sp2.xml

Answer 1

我不确定是什么导致了您的异常，但我确实看到了一些您应该解决的问题:

1. 配置问题:

   看起来您正在使用 FIX50SP2，因此您需要:

   • UseDataDictionary=Y
   • AppDataDictionary=
   • TransportDataDictionary=

   (在提问者的初始编辑中，这些字段不存在)

   而且我不认为您需要ValidateIncomingMessage=N。此设置总是告诉我有人不知道他们在做什么!如果您的连接使用的是重复组(而且我从未见过不使用的组)，则您必须有一个正确的 DD。如果您的 DD 正确，则无需担心验证。

   还有，你真的需要CheckLatency=N吗？

2. 您可能确实需要一个 SecurityStatus 处理程序

   Security Status does not have onMessage function because I am not using this message so I do not expect to handle other type of messages.

   如果您不提供 onMessage(SecurityStatus) 处理程序，那么您的应用程序将以 35=j 拒绝响应这些消息。如果您真的想忽略此消息，那么您应该使用空实现添加此处理程序。