From cc0a697e362e0d9a4f9bb1b3ec6dcf38fcd15be3 Mon Sep 17 00:00:00 2001 From: Antonio Fermiano Date: Tue, 14 Mar 2023 09:09:45 -0300 Subject: [PATCH] Changing BusinessRejectReason in BusinessMessageReject for BinaryEntryPoint protocol --- .../binary_entrypoint/InternalBinaryEntryPointConnection.java | 2 +- .../real_logic/artio/system_tests/BinaryEntryPointClient.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/artio-binary-entrypoint-impl/src/main/java/uk/co/real_logic/artio/binary_entrypoint/InternalBinaryEntryPointConnection.java b/artio-binary-entrypoint-impl/src/main/java/uk/co/real_logic/artio/binary_entrypoint/InternalBinaryEntryPointConnection.java index 2c3b2e9ba7..42c27c1578 100644 --- a/artio-binary-entrypoint-impl/src/main/java/uk/co/real_logic/artio/binary_entrypoint/InternalBinaryEntryPointConnection.java +++ b/artio-binary-entrypoint-impl/src/main/java/uk/co/real_logic/artio/binary_entrypoint/InternalBinaryEntryPointConnection.java @@ -58,7 +58,7 @@ class InternalBinaryEntryPointConnection extends InternalFixPConnection implements BinaryEntryPointConnection { private static final UnsafeBuffer EMPTY_BUFFER = new UnsafeBuffer(new byte[0]); - private static final int THROTTLE_REASON = 99; + private static final int THROTTLE_REASON = 33000; private final BinaryEntryPointProxy proxy; private final long maxFixPKeepaliveTimeoutInMs; diff --git a/artio-binary-entrypoint-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/BinaryEntryPointClient.java b/artio-binary-entrypoint-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/BinaryEntryPointClient.java index 114bd46cee..0a5abe7844 100644 --- a/artio-binary-entrypoint-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/BinaryEntryPointClient.java +++ b/artio-binary-entrypoint-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/BinaryEntryPointClient.java @@ -676,6 +676,6 @@ public void readBusinessReject(final long refSeqNum, final long rejectRefID) assertEquals(refSeqNum, businessReject.refSeqNum()); assertEquals(MessageType.NewOrderSingle, businessReject.refMsgType()); assertEquals(rejectRefID, businessReject.businessRejectRefID()); - assertEquals(99, businessReject.businessRejectReason()); + assertEquals(33000, businessReject.businessRejectReason()); } }